You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by mx...@apache.org on 2020/03/12 10:24:31 UTC
[beam] branch master updated (bb9826c -> 38ba550)
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 bb9826c Merge pull request #11005 from [BEAM-8335] Modify the StreamingCache to subclass the CacheManager
add 4a84aed [BEAM-9298] Drop support for Flink 1.7
add 38ba550 Merge pull request #10884: [BEAM-9298] Drop support for Flink 1.7
No new revisions were added by this update.
Summary of changes:
.../src/main/scripts/build_release_candidate.sh | 2 +-
runners/flink/1.10/build.gradle | 4 +-
runners/flink/1.7/build.gradle | 34 ---
.../flink/1.7/job-server-container/build.gradle | 26 ---
runners/flink/1.7/job-server/build.gradle | 31 ---
.../translation/types/CoderTypeSerializer.java | 227 ---------------------
.../translation/types/EncodedValueSerializer.java | 94 ---------
.../beam/runners/flink/RemoteMiniClusterImpl.java | 67 ------
.../FlinkBroadcastStateInternalsTest.java | 94 ---------
.../flink/streaming/FlinkStateInternalsTest.java | 145 -------------
.../translation/types/CoderTypeSerializerTest.java | 74 -------
runners/flink/1.8/build.gradle | 4 +-
.../flink/BeamFlinkRemoteStreamEnvironment.java | 0
.../streaming/io/BeamStoppableFunction.java | 0
.../apache/beam/runners/flink/FlinkRunnerTest.java | 0
.../runners/flink/streaming/StreamSources.java | 0
runners/flink/1.9/build.gradle | 4 +-
runners/flink/flink_runner.gradle | 6 +-
settings.gradle | 4 -
website/src/contribute/release-guide.md | 2 +-
website/src/documentation/runners/flink.md | 12 +-
website/src/documentation/runtime/environments.md | 2 +-
22 files changed, 14 insertions(+), 818 deletions(-)
delete mode 100644 runners/flink/1.7/build.gradle
delete mode 100644 runners/flink/1.7/job-server-container/build.gradle
delete mode 100644 runners/flink/1.7/job-server/build.gradle
delete mode 100644 runners/flink/1.7/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java
delete mode 100644 runners/flink/1.7/src/main/java/org/apache/beam/runners/flink/translation/types/EncodedValueSerializer.java
delete mode 100644 runners/flink/1.7/src/test/java/org/apache/beam/runners/flink/RemoteMiniClusterImpl.java
delete mode 100644 runners/flink/1.7/src/test/java/org/apache/beam/runners/flink/streaming/FlinkBroadcastStateInternalsTest.java
delete mode 100644 runners/flink/1.7/src/test/java/org/apache/beam/runners/flink/streaming/FlinkStateInternalsTest.java
delete mode 100644 runners/flink/1.7/src/test/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializerTest.java
rename runners/flink/{1.7 => 1.8}/src/main/java/org/apache/beam/runners/flink/BeamFlinkRemoteStreamEnvironment.java (100%)
rename runners/flink/{1.7 => 1.8}/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/BeamStoppableFunction.java (100%)
rename runners/flink/{1.7 => 1.8}/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTest.java (100%)
rename runners/flink/{1.7 => 1.8}/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java (100%)