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..1f3c3f7 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.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 @@ public class ConditionalResolverSkewJoin implements ConditionalResolver, Serializable { private static final long serialVersionUID = 1L; + private static final Logger LOG = LoggerFactory.getLogger(ConditionalResolverSkewJoin.class); + /** * ConditionalResolverSkewJoinCtx. * @@ -118,7 +122,7 @@ public ConditionalResolverSkewJoin() { } } } catch (IOException e) { - e.printStackTrace(); + LOG.warn("Exception while getting tasks", e); } if (resTsks.isEmpty() && ctx.getNoSkewTask() != null) { resTsks.addAll(ctx.getNoSkewTask());