diff --git llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/FunctionLocalizer.java llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/FunctionLocalizer.java index 315c5becb3..e50c11a610 100644 --- llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/FunctionLocalizer.java +++ llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/FunctionLocalizer.java @@ -45,6 +45,7 @@ import org.apache.hadoop.hive.ql.session.SessionState.ResourceType; import org.apache.hadoop.hive.ql.udf.generic.GenericUDFBridge; import org.apache.hadoop.hive.ql.util.ResourceDownloader; +import org.apache.tez.common.TezClassLoader; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -73,7 +74,7 @@ public FunctionLocalizer(Configuration conf, String localDir) { this.conf = conf; this.localDir = new File(localDir, DIR_NAME); AddToClassPathAction addAction = new AddToClassPathAction( - Thread.currentThread().getContextClassLoader(), Collections.emptyList(), true); + TezClassLoader.getInstance(), Collections.emptyList(), true); this.executorClassloader = AccessController.doPrivileged(addAction); this.workThread = new Thread(new Runnable() { @Override diff --git llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java index abf28f2bed..bb1264036c 100644 --- llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java +++ llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/LlapDaemon.java @@ -87,6 +87,7 @@ import org.apache.hive.common.util.HiveVersionInfo; import org.apache.hive.common.util.ShutdownHookManager; import org.apache.logging.log4j.core.config.Configurator; +import org.apache.tez.common.TezClassLoader; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -171,6 +172,7 @@ public LlapDaemon(Configuration daemonConf, int numExecutors, long executorMemor throw new RuntimeException(ex); } + TezClassLoader.setupTezClassLoader(); this.maxJvmMemory = getTotalHeapSize(); this.llapIoEnabled = ioEnabled;