diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractFileMergeOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractFileMergeOperator.java index bb89f803d5..9a3258115b 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractFileMergeOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/AbstractFileMergeOperator.java @@ -110,9 +110,7 @@ public void initializeOp(Configuration hconf) throws HiveException { // sets up temp and task temp path private void updatePaths(Path tp, Path ttp) { - if (taskId == null) { - taskId = Utilities.getTaskId(jc); - } + taskId = Utilities.getTaskId(jc); tmpPath = tp; if (isMmTable) { taskTmpPath = null;