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 ee08991 Merge pull request #12592 from [BEAM-8025] Update tests to
use TemporaryFolder instead of rolling their own implementation.
add 5893ee4 [BEAM-10612] Add flink 1.11 runner
add efad73c Merge pull request #12564: [BEAM-10612] Add Flink 1.11 Runner
No new revisions were added by this update.
Summary of changes:
.../apache/beam/runners/flink/FlinkRunnerTest.java | 96 ----------------------
.../beam/runners/flink/FlinkRunnerTestCompat.java | 42 ++++++++++
runners/flink/{1.10 => 1.11}/build.gradle | 8 +-
.../job-server-container/build.gradle | 0
.../flink/{1.10 => 1.11}/job-server/build.gradle | 2 +-
.../streaming/AbstractStreamOperatorCompat.java} | 14 +++-
.../beam/runners/flink/FlinkRunnerTestCompat.java | 47 +++++++++++
.../beam/runners/flink/RemoteMiniClusterImpl.java | 31 ++++---
.../runners/flink/SourceTransformationCompat.java} | 11 ++-
.../streaming/AbstractStreamOperatorCompat.java} | 14 +++-
.../beam/runners/flink/FlinkRunnerTestCompat.java | 43 ++++++++++
.../runners/flink/SourceTransformationCompat.java} | 12 ++-
runners/flink/flink_runner.gradle | 4 +
.../wrappers/streaming/DoFnOperator.java | 9 +-
.../streaming/io/UnboundedSourceWrapper.java | 2 +-
.../apache/beam/runners/flink/FlinkRunnerTest.java | 10 +--
.../FlinkStreamingTransformTranslatorsTest.java | 21 +++--
.../wrappers/streaming/DoFnOperatorTest.java | 8 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 8 +-
.../src/main/resources/beam/suppressions.xml | 1 +
settings.gradle | 4 +
21 files changed, 234 insertions(+), 153 deletions(-)
delete mode 100644
runners/flink/1.10/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTest.java
create mode 100644
runners/flink/1.10/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTestCompat.java
copy runners/flink/{1.10 => 1.11}/build.gradle (84%)
copy runners/flink/{1.9 => 1.11}/job-server-container/build.gradle (100%)
copy runners/flink/{1.10 => 1.11}/job-server/build.gradle (95%)
copy
runners/flink/{src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/package-info.java
=>
1.11/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/AbstractStreamOperatorCompat.java}
(62%)
create mode 100644
runners/flink/1.11/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTestCompat.java
copy runners/flink/{1.8 =>
1.11}/src/test/java/org/apache/beam/runners/flink/RemoteMiniClusterImpl.java
(69%)
copy
runners/flink/{src/main/java/org/apache/beam/runners/flink/FlinkStateBackendFactory.java
=>
1.11/src/test/java/org/apache/beam/runners/flink/SourceTransformationCompat.java}
(67%)
copy
runners/flink/{src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/package-info.java
=>
1.8/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/AbstractStreamOperatorCompat.java}
(62%)
create mode 100644
runners/flink/1.8/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTestCompat.java
copy
runners/flink/{src/main/java/org/apache/beam/runners/flink/package-info.java =>
1.8/src/test/java/org/apache/beam/runners/flink/SourceTransformationCompat.java}
(68%)
rename runners/flink/{1.8 =>
}/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTest.java (90%)
