This is an automated email from the ASF dual-hosted git repository. damccorm pushed a change to branch users/damccorm/flink-fixes in repository https://gitbox.apache.org/repos/asf/beam.git
from 2c82146993a Try original fix with updated paths add 71218732dc0 Try adding option to flinkOptions No new revisions were added by this update. Summary of changes: sdks/python/apache_beam/options/pipeline_options.py | 1 + sdks/python/apache_beam/runners/portability/flink_runner.py | 6 +++++- sdks/python/test-suites/portable/common.gradle | 2 +- 3 files changed, 7 insertions(+), 2 deletions(-)