diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java index d74c971..5d9c651 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java @@ -920,7 +920,7 @@ protected FSPaths getDynOutPaths(List row, String lbDirName) throws Hive pathKey = dpDir; if(conf.getDpSortState().equals(DPSortState.PARTITION_BUCKET_SORTED)) { String buckNum = row.get(row.size() - 1); - taskId = Utilities.replaceTaskIdFromFilename(Utilities.getTaskId(hconf), buckNum); + taskId = Utilities.replaceTaskIdFromFilename(taskId, buckNum); pathKey = appendToSource(taskId, dpDir); } FSPaths fsp2 = valToPaths.get(pathKey);