You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by we...@apache.org on 2017/05/08 22:17:53 UTC
[36/50] [abbrv] hive git commit: HIVE-16598 : LlapServiceDriver -
create directories and warn of errors (Sergey Shelukhin,
reviewed by Prasanth Jayachandran)
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/hive-14535
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