[HUDI-4551] Tweak the default parallelism of flink pipeline to execution env paralle... master
authorNicholas Jiang <programgeek@163.com>
Thu, 18 Aug 2022 08:13:28 +0000 (16:13 +0800)
committerGitHub <noreply@github.com>
Thu, 18 Aug 2022 08:13:28 +0000 (16:13 +0800)
commitefd9dab14cdea9ec2b09d79499fa95d5584df4fa
treecb7cb593f76a764b8c33809b9c0ddb96165df538
parent9055b2f65d670c2b153c7492ca323188b84c3362
[HUDI-4551] Tweak the default parallelism of flink pipeline to execution env  parallelism (#6312)
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsInference.java [new file with mode: 0644]
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/cluster/ITTestHoodieFlinkClustering.java
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/ITTestHoodieFlinkCompactor.java
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java