You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by da...@apache.org on 2018/04/29 18:32:14 UTC
hive git commit: HIVE-19054: Function replication shall use
"hive.repl.replica.functions.root.dir" as root (Daniel Dai,
reviewed by Thejas Nair)
Repository: hive
Updated Branches:
refs/heads/master 95bdb2b1a -> bfa8e38b8
HIVE-19054: Function replication shall use "hive.repl.replica.functions.root.dir" as root (Daniel Dai, reviewed by Thejas Nair)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/bfa8e38b
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/bfa8e38b
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/bfa8e38b
Branch: refs/heads/master
Commit: bfa8e38b80b3c9d161bb093bb5c3cb60c0422fc3
Parents: 95bdb2b
Author: Daniel Dai <da...@gmail.com>
Authored: Sun Apr 29 11:31:48 2018 -0700
Committer: Daniel Dai <da...@gmail.com>
Committed: Sun Apr 29 11:31:48 2018 -0700
----------------------------------------------------------------------
.../hive/ql/parse/repl/load/message/CreateFunctionHandler.java | 2 +-
.../repl/load/message/TestPrimaryToReplicaResourceFunction.java | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/bfa8e38b/ql/src/java/org/apache/hadoop/hive/ql/parse/repl/load/message/CreateFunctionHandler.java
----------------------------------------------------------------------
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 @@ public class CreateFunctionHandler extends AbstractMessageHandler {
.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(
http://git-wip-us.apache.org/repos/asf/hive/blob/bfa8e38b/ql/src/test/org/apache/hadoop/hive/ql/parse/repl/load/message/TestPrimaryToReplicaResourceFunction.java
----------------------------------------------------------------------
diff --git a/ql/src/test/org/apache/hadoop/hive/ql/parse/repl/load/message/TestPrimaryToReplicaResourceFunction.java b/ql/src/test/org/apache/hadoop/hive/ql/parse/repl/load/message/TestPrimaryToReplicaResourceFunction.java
index 49620f9..7b6c3e7 100644
--- a/ql/src/test/org/apache/hadoop/hive/ql/parse/repl/load/message/TestPrimaryToReplicaResourceFunction.java
+++ b/ql/src/test/org/apache/hadoop/hive/ql/parse/repl/load/message/TestPrimaryToReplicaResourceFunction.java
@@ -83,6 +83,7 @@ public class TestPrimaryToReplicaResourceFunction {
public void createDestinationPath() throws IOException, SemanticException, URISyntaxException {
mockStatic(FileSystem.class);
when(FileSystem.get(any(Configuration.class))).thenReturn(mockFs);
+ when(FileSystem.get(any(URI.class), any(Configuration.class))).thenReturn(mockFs);
when(mockFs.getScheme()).thenReturn("hdfs");
when(mockFs.getUri()).thenReturn(new URI("hdfs", "somehost:9000", null, null, null));
mockStatic(System.class);