This change would unblock somewhat (we also need the parallelism for testing). But rather than limiting it to the 2 Flink parameters, why not just pass all options that the user specified to the runner?
@robertwb can you take a look as well? [ Full content available at: https://github.com/apache/beam/pull/6447 ] This message was relayed via gitbox.apache.org for [email protected]
