flinkMaster is set to `[auto]` before *test* pipeline execution, if unset. With #6426 (not merged) it always defaults to `[auto]`.
`[auto]` can be used when a) testing locally b) submitting using the flink CLI, where the job jar file will already be staged and no additional files need to be staged. So this shouldn't break anything. Whenever we change code like this we should ideally add tests (which you did for the new class). Additional tests for the staging in `FlinkPipelineExecutionEnvironmentTest` would be nice, but we can also do it in a follow-up. [ Full content available at: https://github.com/apache/beam/pull/6244 ] This message was relayed via gitbox.apache.org for [email protected]
