Skip to content

Instantly share code, notes, and snippets.

@jnh5y
Created April 17, 2016 19:01
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save jnh5y/1739baa42466d66e383fa26ffd7235ca to your computer and use it in GitHub Desktop.
Save jnh5y/1739baa42466d66e383fa26ffd7235ca to your computer and use it in GitHub Desktop.
Bean to register Hadoop URL StreamHandlerFactory
import java.net.URL
import org.apache.hadoop.fs.FsUrlStreamHandlerFactory
import org.apache.naming.resources.DirContextURLStreamHandlerFactory
class HadoopURLFactoryRegister {
println("Trying to register the Hadoop URL handlers.")
val factory = new FsUrlStreamHandlerFactory
try {
println("Trying to call the general URL method")
URL.setURLStreamHandlerFactory(factory)
} catch {
case e: Error => println("Caught an exception; falling back to Tomcat specific approach", e)
try {
println("Trying the Tomcat/Catalina specific method.")
DirContextURLStreamHandlerFactory.addUserFactory(factory)
} catch {
case e: Exception => println("Caught an exception: ", e)
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment