Skip to content

Commit d9ddbfe

Browse files
committed
Merge branch 'master' of github.com:TongruiLi/beam into java_portable_runner
2 parents a2c8477 + 9c155f0 commit d9ddbfe

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

sdks/go/pkg/beam/runners/dataflow/dataflow.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -352,7 +352,7 @@ func getJobOptions(ctx context.Context, streaming bool) (*dataflowlib.JobOptions
352352
if strings.Contains(e, "enable_portable_runner") {
353353
portableRunnerSet = true
354354
}
355-
if strings.Contains(e, "disable_runner_v2") || strings.Contains(e, "disable_runner_v2_until_2023") || strings.Contains(e, "disable_prime_runner_v2") || strings.Contains(e, "disable_portable_runner") || strings.Contains(e, "enable_java_streaming_runner") {
355+
if strings.Contains(e, "disable_runner_v2") || strings.Contains(e, "disable_runner_v2_until_2023") || strings.Contains(e, "disable_prime_runner_v2") || strings.Contains(e, "disable_portable_runner") || strings.Contains(e, "enable_streaming_java_runner") {
356356
return nil, errors.New("detected one of the following experiments: disable_runner_v2 | disable_runner_v2_until_2023 | disable_prime_runner_v2. Disabling runner v2 is no longer supported as of Beam version 2.45.0+")
357357
}
358358
}

0 commit comments

Comments
 (0)