[HUDI-5085]When a flink job has multiple sink tables, the index loadi…

…ng status is abnormal (apache#7051)
onehouseinc · Dec 14, 2022 · f0e1eb1 · f0e1eb1
1 parent d5745cc
commit f0e1eb1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java b/...datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java
@@ -160,7 +160,7 @@ private void waitForBootstrapReady(int taskID) {
     int readyTaskNum = 1;
     while (taskNum != readyTaskNum) {
       try {
-        readyTaskNum = aggregateManager.updateGlobalAggregate(BootstrapAggFunction.NAME, taskID, new BootstrapAggFunction());
+        readyTaskNum = aggregateManager.updateGlobalAggregate(BootstrapAggFunction.NAME + conf.getString(FlinkOptions.TABLE_NAME), taskID, new BootstrapAggFunction());
         LOG.info("Waiting for other bootstrap tasks to complete, taskId = {}.", taskID);
 
         TimeUnit.SECONDS.sleep(5);