diff --git a/ql/src/java/org/apache/hadoop/hive/ql/Context.java b/ql/src/java/org/apache/hadoop/hive/ql/Context.java index 70846ac..0fedf0e 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/Context.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/Context.java @@ -98,7 +98,7 @@ // Keeps track of scratch directories created for different scheme/authority private final Map fsScratchDirs = new HashMap(); - private final Configuration conf; + private Configuration conf; protected int pathid = 10000; protected ExplainConfiguration explainConfig = null; protected String cboInfo; @@ -1067,4 +1067,8 @@ public int getExecutionIndex() { public void setExecutionIndex(int executionIndex) { this.executionIndex = executionIndex; } + + public void setConf(HiveConf conf) { + this.conf = conf; + } } diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/load/message/TableHandler.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/load/message/TableHandler.java index 04a7654..e9b6d3d 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/load/message/TableHandler.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/load/message/TableHandler.java @@ -32,6 +32,7 @@ try { List> importTasks = new ArrayList<>(); + context.nestedContext.setConf(context.hiveConf); EximUtil.SemanticAnalyzerWrapperContext x = new EximUtil.SemanticAnalyzerWrapperContext( context.hiveConf, context.db, readEntitySet, writeEntitySet, importTasks, context.log,