This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 2c96aeb Merge pull request #13405 from [BEAM-10703, BEAM-10475] Add
GroupIntoBatches to runner API; add Dataflow override in Python SDK
add 62f385c [BEAM-11419] Add Flink 1.12 build target.
add a35513d Merge pull request #13504: [BEAM-11419] Add Flink 1.12 build
target
No new revisions were added by this update.
Summary of changes:
.../runners/flink/streaming/StreamSources.java | 13 +++++++++++
runners/flink/{1.10 => 1.12}/build.gradle | 8 +++----
.../job-server-container/build.gradle | 0
.../flink/{1.8 => 1.12}/job-server/build.gradle | 2 +-
.../streaming/AbstractStreamOperatorCompat.java | 27 ++++++++++++++++++++--
.../runners/flink/streaming/StreamSources.java | 14 +++++++++++
.../runners/flink/streaming/StreamSources.java | 13 +++++++++++
.../runners/flink/streaming/StreamSources.java | 13 +++++++++++
.../wrappers/streaming/DoFnOperator.java | 18 +++++++--------
.../FlinkStreamingTransformTranslatorsTest.java | 7 ++++--
settings.gradle | 4 ++++
11 files changed, 101 insertions(+), 18 deletions(-)
copy runners/flink/{1.10 => 1.12}/build.gradle (80%)
copy runners/flink/{1.9 => 1.12}/job-server-container/build.gradle (100%)
copy runners/flink/{1.8 => 1.12}/job-server/build.gradle (95%)
copy runners/flink/{1.8 =>
1.12}/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/AbstractStreamOperatorCompat.java
(59%)
copy runners/flink/{1.10 =>
1.12}/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java
(80%)
