From f0e1eb187cf855b7b8ae47290df14da350688814 Mon Sep 17 00:00:00 2001
From: YangXiao <919869387@qq.com>
Date: Wed, 26 Oct 2022 16:44:26 +0800
Subject: [PATCH] [HUDI-5085]When a flink job has multiple sink tables, the
 index loading status is abnormal (#7051)

---
 .../java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java
index 10d46abc94cac..09250e31328ae 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java
+++ b/hudi-flink-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);