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 <ieme...@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(-)