[INLONG-10355][Sort] fix defect

XiaoYou201 · Jul 2, 2024 · 8fd27f8 · 8fd27f8
1 parent 22526a9
commit 8fd27f8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ava/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java b/...ava/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java
@@ -340,9 +340,9 @@ public void initializeState(FunctionInitializationContext functionInitialization
 
  @Override
  public void notifyCheckpointComplete(long checkpointId) {
+ commitTransaction(checkpointId);
  flushAudit();
  updateLastCheckpointId(checkpointId);
- commitTransaction(checkpointId);
  }
 
  private void commitTransaction(long checkpointId) {