diff --git ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java index 5d25007d77..8e81e4126f 100644 --- ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java +++ 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; + static final protected Logger LOG = LoggerFactory.getLogger(ConditionalResolverSkewJoin.class); + /** * ConditionalResolverSkewJoinCtx. * @@ -118,12 +122,12 @@ public ConditionalResolverSkewJoin() { } } } catch (IOException e) { - e.printStackTrace(); + // e.printStackTrace(); + LOG.warn("IOException while getting the bigKeysPaths - dirToTaskMap -getTasks method", e); } if (resTsks.isEmpty() && ctx.getNoSkewTask() != null) { resTsks.addAll(ctx.getNoSkewTask()); } return resTsks; } - }