You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/03/25 04:55:41 UTC
[beam] branch nightly-refs/heads/master updated (14862cc -> 0c93be1)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 14862cc Moving to 2.39.0-SNAPSHOT on master branch.
add 993061a [BEAM-14157] Don't call requestObserver.onNext on a closed windmill streams (#17162)
add 6cddf29 Minor: Make IOTypeHints a real NamedTuple (#17174)
add 12530a3 [BEAM-14139] Drop support for Flink 1.11.
add 868a773 [BEAM-14139] Remove obsolete reference to Flink 1.11.
add e63bc2d [BEAM-14139] Update list of supported Flink versions.
add 11d6aad [BEAM-14139] Update CHANGES.md
add 141fb79 Merge pull request #17145 from ibzib/no-flink11
add 0c93be1 [BEAM-14172] Update tox.ini for pydocs (#17176)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 31 ++++++++
gradle.properties | 2 +-
runners/flink/1.11/build.gradle | 33 --------
.../flink/1.11/job-server-container/build.gradle | 26 ------
runners/flink/1.11/job-server/build.gradle | 31 --------
.../streaming/AbstractStreamOperatorCompat.java | 61 --------------
.../beam/runners/flink/FlinkRunnerTestCompat.java | 47 -----------
.../runners/flink/SourceTransformationCompat.java | 28 -------
runners/flink/1.12/build.gradle | 4 +-
.../beam/runners/flink/RemoteMiniClusterImpl.java | 0
.../runners/flink/metrics/MetricGroupWrapper.java | 0
.../runners/flink/streaming/StreamSources.java | 22 +-----
runners/flink/1.13/build.gradle | 4 +-
.../runners/flink/streaming/StreamSources.java | 92 ----------------------
runners/flink/1.14/build.gradle | 4 +-
.../runners/flink/streaming/StreamSources.java | 22 +-----
.../apache/beam/runners/flink/FlinkRunnerTest.java | 41 ++++++----
.../beam/runners/flink/FlinkSavepointTest.java | 4 -
.../FlinkStreamingTransformTranslatorsTest.java | 13 +--
.../dataflow/worker/StreamingDataflowWorker.java | 6 +-
.../worker/windmill/GrpcWindmillServer.java | 3 +
.../python/apache_beam/options/pipeline_options.py | 2 +-
sdks/python/apache_beam/typehints/decorators.py | 18 ++---
sdks/python/tox.ini | 1 +
settings.gradle.kts | 4 -
25 files changed, 91 insertions(+), 408 deletions(-)
delete mode 100644 runners/flink/1.11/build.gradle
delete mode 100644 runners/flink/1.11/job-server-container/build.gradle
delete mode 100644 runners/flink/1.11/job-server/build.gradle
delete mode 100644 runners/flink/1.11/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/AbstractStreamOperatorCompat.java
delete mode 100644 runners/flink/1.11/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTestCompat.java
delete mode 100644 runners/flink/1.11/src/test/java/org/apache/beam/runners/flink/SourceTransformationCompat.java
rename runners/flink/{1.11 => 1.12}/src/test/java/org/apache/beam/runners/flink/RemoteMiniClusterImpl.java (100%)
rename runners/flink/{1.11 => 1.12}/src/test/java/org/apache/beam/runners/flink/metrics/MetricGroupWrapper.java (100%)
delete mode 100644 runners/flink/1.13/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java