You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pv...@apache.org on 2019/01/08 11:19:19 UTC
hive git commit: HIVE-20159: Do Not Print StackTraces to STDERR in
ConditionalResolverSkewJoin (Mani M, reviewed by BELUGA BEHR and Peter Vary)
Repository: hive
Updated Branches:
refs/heads/master b3ef75eaa -> e92df8dd6
HIVE-20159: Do Not Print StackTraces to STDERR in ConditionalResolverSkewJoin (Mani M, reviewed by BELUGA BEHR and Peter Vary)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/e92df8dd
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/e92df8dd
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/e92df8dd
Branch: refs/heads/master
Commit: e92df8dd6aae2dffa24cabbfce343704a7fe9a04
Parents: b3ef75e
Author: Mani M <rm...@gmail.com>
Authored: Tue Jan 8 12:18:20 2019 +0100
Committer: Peter Vary <pv...@cloudera.com>
Committed: Tue Jan 8 12:18:20 2019 +0100
----------------------------------------------------------------------
.../hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/e92df8dd/ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java b/ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java
index 5d25007..5dd7a25 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java
@@ -32,6 +32,8 @@ import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.ql.exec.Task;
import org.apache.hadoop.hive.ql.exec.Utilities;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* ConditionalResolverSkewJoin.
@@ -40,6 +42,8 @@ import org.apache.hadoop.hive.ql.exec.Utilities;
public class ConditionalResolverSkewJoin implements ConditionalResolver, Serializable {
private static final long serialVersionUID = 1L;
+ static final protected Logger LOG = LoggerFactory.getLogger(ConditionalResolverSkewJoin.class);
+
/**
* ConditionalResolverSkewJoinCtx.
*
@@ -118,7 +122,7 @@ public class ConditionalResolverSkewJoin implements ConditionalResolver, Seriali
}
}
} catch (IOException e) {
- e.printStackTrace();
+ LOG.warn("Exception while getting tasks", e);
}
if (resTsks.isEmpty() && ctx.getNoSkewTask() != null) {
resTsks.addAll(ctx.getNoSkewTask());