(hudi) branch master updated: [MINOR] Restore the setMaxParallelism setting for HoodieTableSource.produceDataStream (#10925)

[danny0405]

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

danny0405 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 d22bfba08fd [MINOR] Restore the setMaxParallelism setting for 
HoodieTableSource.produceDataStream (#10925)
d22bfba08fd is described below

commit d22bfba08fde3814aee627d06837191c3bfe5a50
Author: zhuanshenbsj1 <34104400+zhuanshenb...@users.noreply.github.com>
AuthorDate: Tue Mar 26 13:30:07 2024 +0800

    [MINOR] Restore the setMaxParallelism setting for 
HoodieTableSource.produceDataStream (#10925)
---
 .../src/main/java/org/apache/hudi/table/HoodieTableSource.java         | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java
 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java
index 8e27aafd2a3..b4cfdbb0c9f 100644
--- 
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java
+++ 
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java
@@ -210,7 +210,8 @@ public class HoodieTableSource implements
           OneInputStreamOperatorFactory<MergeOnReadInputSplit, RowData> 
factory = StreamReadOperator.factory((MergeOnReadInputFormat) inputFormat);
           SingleOutputStreamOperator<MergeOnReadInputSplit> 
monitorOperatorStream = execEnv.addSource(monitoringFunction, 
getSourceOperatorName("split_monitor"))
               .uid(Pipelines.opUID("split_monitor", conf))
-              .setParallelism(1);
+              .setParallelism(1)
+              .setMaxParallelism(1);
 
           DataStream<MergeOnReadInputSplit> sourceWithKey = 
addFileDistributionStrategy(monitorOperatorStream);