diff --git ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverMergeFiles.java ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverMergeFiles.java index 80f77b9f0c..c19cb10dab 100644 --- ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverMergeFiles.java +++ ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverMergeFiles.java @@ -34,6 +34,8 @@ import org.apache.hadoop.hive.metastore.Warehouse; import org.apache.hadoop.hive.ql.exec.Task; import org.apache.hadoop.hive.ql.exec.Utilities; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * Conditional task resolution interface. This is invoked at run time to get the @@ -43,6 +45,8 @@ Serializable { private static final long serialVersionUID = 1L; + static final protected Logger LOG = LoggerFactory.getLogger(ConditionalResolverMergeFiles.class); + public ConditionalResolverMergeFiles() { } @@ -190,7 +194,7 @@ public void setLbCtx(ListBucketingCtx lbCtx) { resTsks.add(mvTask); } } catch (IOException e) { - e.printStackTrace(); + LOG.warn("Exception while getting tasks", e); } // Only one of the tasks should ever be added to resTsks