You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2022/11/22 15:34:41 UTC
[beam] branch users/damccorm/flink-fixes updated (2c82146993a -> 71218732dc0)
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(-)