[Flink] set validates runner parallelism to 1

apache · Nov 14, 2024 · 777dcf7 · 777dcf7
1 parent e359eda
commit 777dcf7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/runners/flink/flink_runner.gradle b/runners/flink/flink_runner.gradle
@@ -249,7 +249,7 @@ def createValidatesRunnerTask(Map m) {
     def pipelineOptionsArray = ["--runner=TestFlinkRunner",
                                 "--streaming=${config.streaming}",
                                 "--useDataStreamForBatch=${config.useDataStreamForBatch}",
-                                "--parallelism=2",
+                                "--parallelism=1",
     ]
     if (config.checkpointing) {
       pipelineOptionsArray.addAll([