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 2575d9d [BEAM-8405] Support embedded Datastore entities (#9805)
add f454f97 [BEAM-7730] Introduce Flink 1.9 Runner.
add 4a64965 [BEAM-7730] Reuse sources overrides from previous flink
versions.
add d34bbbd [BEAM-7730] Fix spotless plugin for flink runner.
add 686bfd2 Merge pull request #9296: [BEAM-7730] Introduce Flink 1.9
Runner
No new revisions were added by this update.
Summary of changes:
examples/java/build.gradle | 2 +-
examples/kotlin/build.gradle | 2 +-
runners/flink/1.7/build.gradle | 8 ++--
.../streaming/io/BeamStoppableFunction.java} | 13 +++++-
.../runners/flink/streaming/StreamSources.java} | 21 +++++++++-
runners/flink/1.8/build.gradle | 8 ++--
runners/flink/{1.7 => 1.9}/build.gradle | 13 +++---
.../{1.8 => 1.9}/job-server-container/build.gradle | 0
runners/flink/{1.8 => 1.9}/job-server/build.gradle | 2 +-
.../streaming/io/BeamStoppableFunction.java} | 15 ++++++-
.../runners/flink/streaming/StreamSources.java | 49 ++++++++++++++++++++++
runners/flink/flink_runner.gradle | 39 +++++++++++++----
.../flink/FlinkStreamingTransformTranslators.java | 4 +-
.../streaming/io/UnboundedSourceWrapper.java | 7 +++-
.../FlinkStreamingTransformTranslatorsTest.java | 37 ++++++++--------
.../flink/streaming/BoundedSourceRestoreTest.java | 6 ++-
.../wrappers/streaming/DoFnOperatorTest.java | 3 +-
.../streaming/io/UnboundedSourceWrapperTest.java | 13 ++++--
.../src/main/resources/beam/suppressions.xml | 1 +
sdks/java/maven-archetypes/examples/build.gradle | 2 +-
settings.gradle | 4 ++
21 files changed, 182 insertions(+), 67 deletions(-)
copy
runners/flink/{src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/package-info.java
=>
1.7/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/BeamStoppableFunction.java}
(71%)
copy
runners/flink/{src/test/java/org/apache/beam/runners/flink/streaming/package-info.java
=>
1.7/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java}
(51%)
copy runners/flink/{1.7 => 1.9}/build.gradle (73%)
copy runners/flink/{1.8 => 1.9}/job-server-container/build.gradle (100%)
copy runners/flink/{1.8 => 1.9}/job-server/build.gradle (95%)
copy
runners/flink/{src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/package-info.java
=>
1.9/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/BeamStoppableFunction.java}
(73%)
create mode 100644
runners/flink/1.9/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java
