Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-22701 Disable the DynamicClassLoader when it fails to initialize 

Signed-off-by: Ankit Singhal <ankitsinghal59@gmail.com>
This commit is contained in:
Josh Elser 2019-07-16 17:10:27 -04:00 committed by Sean Busbey
parent 5130bc52d5
commit b566a4f9bc
1 changed files with 23 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
hbase-common/src/main/java/org/apache/hadoop/hbase/util/DynamicClassLoader.java
View File

@ -69,7 +69,10 @@ public class DynamicClassLoader extends ClassLoaderBase {
private static final String DYNAMIC_JARS_OPTIONAL_CONF_KEY = "hbase.use.dynamic.jars";
private static final boolean DYNAMIC_JARS_OPTIONAL_DEFAULT = true;
private boolean useDynamicJars;
// The user-provided value for using the DynamicClassLoader
private final boolean userConfigUseDynamicJars;
// The current state of whether to use the DynamicClassLoader
private final boolean useDynamicJars;
private File localDir;
@ -91,13 +94,24 @@ public class DynamicClassLoader extends ClassLoaderBase {
final Configuration conf, final ClassLoader parent) {
super(parent);
useDynamicJars = conf.getBoolean(
// Save off the user's original configuration value for the DynamicClassLoader
userConfigUseDynamicJars = conf.getBoolean(
DYNAMIC_JARS_OPTIONAL_CONF_KEY, DYNAMIC_JARS_OPTIONAL_DEFAULT);
if (useDynamicJars) {
boolean dynamicJarsEnabled = userConfigUseDynamicJars;
if (dynamicJarsEnabled) {
try {
initTempDir(conf);
dynamicJarsEnabled = true;
} catch (Exception e) {
LOG.error("Disabling the DynamicClassLoader as it failed to initialize its temp directory."
+ " Check your configuration and filesystem permissions. Custom coprocessor code may"
+ " not be loaded as a result of this failure.", e);
dynamicJarsEnabled = false;
}
}
useDynamicJars = dynamicJarsEnabled;
}
// FindBugs: Making synchronized to avoid IS2_INCONSISTENT_SYNC complaints about
// remoteDirFs and jarModifiedTime being part synchronized protected.
@ -132,12 +146,13 @@ public class DynamicClassLoader extends ClassLoaderBase {
try {
return parent.loadClass(name);
} catch (ClassNotFoundException e) {
if (LOG.isDebugEnabled()) {
LOG.debug("Class " + name + " not found - using dynamical class loader");
}
if (useDynamicJars) {
LOG.debug("Class " + name + " not found - using dynamical class loader");
return tryRefreshClass(name);
} else if (userConfigUseDynamicJars) {
// If the user tried to enable the DCL, then warn again.
LOG.debug("Not checking DynamicClassLoader for missing class because it is disabled."
+ " See the log for previous errors.");
}
throw e;
}