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 2019/06/10 11:42:54 UTC

[beam] 01/01: Merge pull request #8787: [release-2.7.1] Flink backports for LTS release

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