diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/load/message/CreateFunctionHandler.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/load/message/CreateFunctionHandler.java index f7c9040..a3331b4 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/load/message/CreateFunctionHandler.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/load/message/CreateFunctionHandler.java @@ -190,7 +190,7 @@ ResourceUri destinationResourceUri(ResourceUri resourceUri) .addDescendant(String.valueOf(System.nanoTime())) .addDescendant(ReplChangeManager.getFileWithChksumFromURI(split[split.length - 1])[0]) .build(), - FileSystem.get(context.hiveConf) + new Path(functionsRootDir).getFileSystem(context.hiveConf) ); Task copyTask = ReplCopyTask.getLoadCopyTask(