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..fb3b694 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 @@ -183,15 +183,13 @@ ResourceUri destinationResourceUri(ResourceUri resourceUri) String sourceUri = resourceUri.getUri(); String[] split = sourceUri.split(Path.SEPARATOR); PathBuilder pathBuilder = new PathBuilder(functionsRootDir); - Path qualifiedDestinationPath = PathBuilder.fullyQualifiedHDFSUri( + Path qualifiedDestinationPath = pathBuilder .addDescendant(destinationDbName.toLowerCase()) .addDescendant(metadata.function.getFunctionName().toLowerCase()) .addDescendant(String.valueOf(System.nanoTime())) .addDescendant(ReplChangeManager.getFileWithChksumFromURI(split[split.length - 1])[0]) - .build(), - FileSystem.get(context.hiveConf) - ); + .build(); Task copyTask = ReplCopyTask.getLoadCopyTask( metadata.getReplicationSpec(), new Path(sourceUri), qualifiedDestinationPath,