You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2019/05/10 14:16:49 UTC
[beam] 01/01: Merge pull request #8540: [BEAM-7145] Make
FlinkRunner compatible with Flink 1.8
This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 01e9878986da31bbba5c9b8dd6749ffdc08718a1
Merge: 6679b00 40da292
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Fri May 10 16:16:29 2019 +0200
Merge pull request #8540: [BEAM-7145] Make FlinkRunner compatible with Flink 1.8
runners/flink/{ => 1.5}/build.gradle | 14 ++--
.../{ => 1.5}/job-server-container/build.gradle | 6 +-
runners/flink/{ => 1.5}/job-server/build.gradle | 2 +-
.../translation/types/CoderTypeSerializer.java | 2 +-
.../translation/types/EncodedValueSerializer.java | 0
.../FlinkBroadcastStateInternalsTest.java | 0
.../flink/streaming/FlinkStateInternalsTest.java | 0
.../translation/types/CoderTypeSerializerTest.java | 0
runners/flink/1.6/build.gradle | 8 +--
runners/flink/1.7/build.gradle | 8 +--
runners/flink/{1.6 => 1.8}/build.gradle | 8 +--
.../{ => 1.8}/job-server-container/build.gradle | 6 +-
runners/flink/{ => 1.8}/job-server/build.gradle | 2 +-
.../translation/types/CoderTypeSerializer.java | 79 +++++-----------------
.../translation/types/EncodedValueSerializer.java | 31 ++++++++-
.../FlinkBroadcastStateInternalsTest.java | 4 +-
.../flink/streaming/FlinkStateInternalsTest.java | 9 ++-
.../translation/types/CoderTypeSerializerTest.java | 25 ++++---
runners/flink/flink_runner.gradle | 4 ++
.../runners/flink/FlinkExecutionEnvironments.java | 10 +--
.../beam/runners/flink/FlinkSavepointTest.java | 24 +++++--
.../src/main/resources/beam/suppressions.xml | 6 ++
settings.gradle | 19 ++++--
23 files changed, 145 insertions(+), 122 deletions(-)