[hudi] branch master updated: [HUDI-5085]When a flink job has multiple sink tables, the index loading status is abnormal (#7051)

[mengtao]

This is an automated email from the ASF dual-hosted git repository.

mengtao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 22ccdc1540 [HUDI-5085]When a flink job has multiple sink tables, the 
index loading status is abnormal (#7051)
22ccdc1540 is described below

commit 22ccdc154008e38b74a4361c2a5aedfaef56a87e
Author: YangXiao <919869...@qq.com>
AuthorDate: Wed Oct 26 16:44:26 2022 +0800

    [HUDI-5085]When a flink job has multiple sink tables, the index loading 
status is abnormal (#7051)
---
 .../src/main/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 10d46abc94..09250e3132 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 @@ public class BootstrapOperator<I, O extends HoodieRecord<?>>
     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);