You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by th...@apache.org on 2018/10/24 15:59:12 UTC

[beam] branch master updated (a87dfe4 -> 5b57fb1)

This is an automated email from the ASF dual-hosted git repository.

thw pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from a87dfe4  Merge pull request #6810: [BEAM-5848] Fix coder for streaming impulse source
     add 72cb032  [BEAM-2918] Add state support for streaming in portable FlinkRunner
     add 5b57fb1  Merge pull request #6726: [BEAM-2918] Add state support for streaming in portable FlinkRunner

No new revisions were added by this update.

Summary of changes:
 .../FlinkStreamingPortablePipelineTranslator.java  |  31 ++++-
 .../flink/FlinkStreamingTransformTranslators.java  |   2 +-
 .../streaming/ExecutableStageDoFnOperator.java     | 146 ++++++++++++++++++---
 ...onTest.java => PortableStateExecutionTest.java} | 127 +++++++++++-------
 .../streaming/ExecutableStageDoFnOperatorTest.java |  15 ++-
 .../FlinkExecutableStageFunctionTest.java          |   7 +
 .../control/DefaultJobBundleFactory.java           |   5 +
 .../SingleEnvironmentInstanceJobBundleFactory.java |   5 +
 .../fnexecution/control/StageBundleFactory.java    |   2 +
 .../harness/state/StateFetchingIteratorsTest.java  |   1 -
 .../runners/portability/flink_runner_test.py       |   5 +-
 11 files changed, 275 insertions(+), 71 deletions(-)
 copy runners/flink/src/test/java/org/apache/beam/runners/flink/{PortableExecutionTest.java => PortableStateExecutionTest.java} (52%)