This is an automated email from the ASF dual-hosted git repository.
mxm pushed a commit to branch release-2.7.1
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 298e54bfeedb45a0ced6fd4a32d80bdbb94e1774
Merge: a882a28 6df381a
Author: Maximilian Michels <m...@apache.org>
AuthorDate: Mon Jun 10 13:42:28 2019 +0200
Merge pull request #8787: [release-2.7.1] Flink backports for LTS release
.../beam/runners/core/StateInternalsTest.java | 92 +++++-
runners/flink/build.gradle | 2 +-
.../runners/flink/DefaultParallelismFactory.java | 39 ---
.../runners/flink/FlinkExecutionEnvironments.java | 76 ++++-
.../apache/beam/runners/flink/FlinkJobInvoker.java | 5 +-
.../flink/FlinkPipelineExecutionEnvironment.java | 10 +
.../beam/runners/flink/FlinkPipelineOptions.java | 11 +-
.../org/apache/beam/runners/flink/FlinkRunner.java | 5 -
.../flink/PipelineTranslationOptimizer.java | 16 +
.../translation/functions/FlinkDoFnFunction.java | 7 +-
.../functions/FlinkStatefulDoFnFunction.java | 7 +-
.../flink/translation/utils/FlinkClassloading.java | 30 ++
.../wrappers/streaming/DoFnOperator.java | 45 ++-
.../streaming/io/UnboundedSourceWrapper.java | 85 +++--
.../state/FlinkBroadcastStateInternals.java | 12 +-
.../streaming/state/FlinkStateInternals.java | 353 ++++++++++++---------
.../flink/FlinkExecutionEnvironmentsTest.java | 162 ++++++++++
.../FlinkPipelineExecutionEnvironmentTest.java | 44 +++
.../beam/runners/flink/PipelineOptionsTest.java | 26 ++
.../flink/streaming/BoundedSourceRestoreTest.java | 1 +
.../runners/flink/streaming/DoFnOperatorTest.java | 49 ++-
.../streaming/FlinkKeyGroupStateInternalsTest.java | 8 +
.../streaming/FlinkSplitStateInternalsTest.java | 8 +
.../flink/streaming/FlinkStateInternalsTest.java | 108 ++++++-
.../flink/streaming/GroupByNullKeyTest.java | 2 +
.../wrappers/streaming/io}/TestCountingSource.java | 15 +-
.../streaming/io}/UnboundedSourceWrapperTest.java | 207 +++++++++---
runners/flink/src/test/resources/flink-conf.yaml | 19 ++
.../spark/stateful/SparkStateInternals.java | 3 +-
29 files changed, 1120 insertions(+), 327 deletions(-)
