beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject [beam] branch master updated (2c96aeb -> a35513d)
Date Wed, 09 Dec 2020 10:25:15 GMT
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%)


Mime
View raw message