You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2017/05/08 19:35:56 UTC
[1/2] hive git commit: HIVE-16598 : LlapServiceDriver - create
directories and warn of errors (Sergey Shelukhin,
reviewed by Prasanth Jayachandran)
Repository: hive
Updated Branches:
refs/heads/branch-2 afc3dabf5 -> 8bf64d63c
refs/heads/master 57beac4ef -> e4856ca03
HIVE-16598 : LlapServiceDriver - create directories and warn of errors (Sergey Shelukhin, reviewed by Prasanth Jayachandran)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/e4856ca0
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/e4856ca0
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/e4856ca0
Branch: refs/heads/master
Commit: e4856ca031ce4776ea8738824e57b213394a7735
Parents: 57beac4
Author: sergey <se...@apache.org>
Authored: Mon May 8 12:34:02 2017 -0700
Committer: sergey <se...@apache.org>
Committed: Mon May 8 12:34:02 2017 -0700
----------------------------------------------------------------------
.../apache/hadoop/hive/llap/cli/LlapServiceDriver.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/e4856ca0/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
----------------------------------------------------------------------
diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java b/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
index a662c75..6bf9550 100644
--- a/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
+++ b/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
@@ -349,7 +349,15 @@ public class LlapServiceDriver {
final Path tezDir = new Path(libDir, "tez");
final Path udfDir = new Path(libDir, "udfs");
final Path confPath = new Path(tmpDir, "conf");
- lfs.mkdirs(confPath);
+ if (!lfs.mkdirs(confPath)) {
+ LOG.warn("mkdirs for " + confPath + " returned false");
+ }
+ if (!lfs.mkdirs(tezDir)) {
+ LOG.warn("mkdirs for " + tezDir + " returned false");
+ }
+ if (!lfs.mkdirs(udfDir)) {
+ LOG.warn("mkdirs for " + udfDir + " returned false");
+ }
NamedCallable<Void> downloadTez = new NamedCallable<Void>("downloadTez") {
@Override
[2/2] hive git commit: HIVE-16598 : LlapServiceDriver - create
directories and warn of errors (Sergey Shelukhin,
reviewed by Prasanth Jayachandran)
Posted by se...@apache.org.
HIVE-16598 : LlapServiceDriver - create directories and warn of errors (Sergey Shelukhin, reviewed by Prasanth Jayachandran)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/8bf64d63
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/8bf64d63
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/8bf64d63
Branch: refs/heads/branch-2
Commit: 8bf64d63ccf660c83776d4dd09c6ca118d65f17a
Parents: afc3dab
Author: sergey <se...@apache.org>
Authored: Mon May 8 12:34:02 2017 -0700
Committer: sergey <se...@apache.org>
Committed: Mon May 8 12:35:16 2017 -0700
----------------------------------------------------------------------
.../apache/hadoop/hive/llap/cli/LlapServiceDriver.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/8bf64d63/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
----------------------------------------------------------------------
diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java b/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
index 22e5ee8..03ca62c 100644
--- a/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
+++ b/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
@@ -348,7 +348,15 @@ public class LlapServiceDriver {
final Path tezDir = new Path(libDir, "tez");
final Path udfDir = new Path(libDir, "udfs");
final Path confPath = new Path(tmpDir, "conf");
- lfs.mkdirs(confPath);
+ if (!lfs.mkdirs(confPath)) {
+ LOG.warn("mkdirs for " + confPath + " returned false");
+ }
+ if (!lfs.mkdirs(tezDir)) {
+ LOG.warn("mkdirs for " + tezDir + " returned false");
+ }
+ if (!lfs.mkdirs(udfDir)) {
+ LOG.warn("mkdirs for " + udfDir + " returned false");
+ }
NamedCallable<Void> downloadTez = new NamedCallable<Void>("downloadTez") {
@Override