diff --git a/sdks/go/test/run_validatesrunner_tests.sh b/sdks/go/test/run_validatesrunner_tests.sh index c4c0dc5eb7e5..49c196e27fc2 100755 --- a/sdks/go/test/run_validatesrunner_tests.sh +++ b/sdks/go/test/run_validatesrunner_tests.sh @@ -262,14 +262,12 @@ elif [[ "$RUNNER" == "flink" || "$RUNNER" == "spark" || "$RUNNER" == "samza" || --job-port $JOB_PORT \ --expansion-port 0 \ --artifact-port 0 & - SIMULTANEOUS=1 elif [[ "$RUNNER" == "samza" ]]; then java \ -jar $SAMZA_JOB_SERVER_JAR \ --job-port $JOB_PORT \ --expansion-port 0 \ --artifact-port 0 & - SIMULTANEOUS=1 elif [[ "$RUNNER" == "spark" ]]; then java \ -jar $SPARK_JOB_SERVER_JAR \ @@ -277,7 +275,6 @@ elif [[ "$RUNNER" == "flink" || "$RUNNER" == "spark" || "$RUNNER" == "samza" || --job-port $JOB_PORT \ --expansion-port 0 \ --artifact-port 0 & - SIMULTANEOUS=1 # Spark runner fails if jobs are run concurrently. elif [[ "$RUNNER" == "portable" ]]; then python3 \ -m apache_beam.runners.portability.local_job_service_main \ @@ -305,6 +302,11 @@ elif [[ "$RUNNER" == "flink" || "$RUNNER" == "spark" || "$RUNNER" == "samza" || fi fi +# Disable parallelism on runners that don't support it. +if [[ "$RUNNER" == "flink" || "$RUNNER" == "spark" || "$RUNNER" == "samza" ]]; then + SIMULTANEOUS=1 +fi + if [[ "$RUNNER" == "dataflow" ]]; then # Verify docker and gcloud commands exist command -v docker