[hotfix-#1052][hive] Replace the call order of HDFSOutputFormat Close…

… and finalizeGlobal
DTStack · Jul 29, 2022 · 54b01f1 · 54b01f1
1 parent 8a45308
commit 54b01f1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...onnector-hive/src/main/java/com/dtstack/chunjun/connector/hive/sink/HiveOutputFormat.java b/...onnector-hive/src/main/java/com/dtstack/chunjun/connector/hive/sink/HiveOutputFormat.java
@@ -246,8 +246,8 @@ public void closeInternal() {
  outputFormatMap.entrySet()) {
  try {
  BaseHdfsOutputFormat format = entry.getValue().getRight();
- format.finalizeGlobal(numTasks);
  format.close();
+ format.finalizeGlobal(numTasks);
  } catch (IOException e) {
  LOG.warn("close {} outputFormat error", entry.getKey(), e);
  }