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/02 01:15:58 UTC

[beam] branch master updated (f219bb1 -> 0eea587)

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 f219bb1  Merge pull request #6527: [BEAM-3652] Port WriteWithShardingFactoryTest off DoFnTester
     add 1fdc2f9  [BEAM-5520] Portable pipeline option to control SDK harness process parallelism.
     add 0eea587  Merge pull request #6524:  [BEAM-5520] Flink pipeline option to run SDK harness per subtask.

No new revisions were added by this update.

Summary of changes:
 .../FlinkBatchPortablePipelineTranslator.java      | 41 ++++++++++------------
 .../beam/runners/flink/FlinkJobInvocation.java     |  6 ++--
 .../apache/beam/runners/flink/FlinkJobInvoker.java | 23 ++++++++----
 .../beam/runners/flink/FlinkJobServerDriver.java   | 23 ++++++++++--
 .../beam/runners/flink/FlinkPipelineOptions.java   |  4 ++-
 .../flink/FlinkPortablePipelineTranslator.java     |  2 ++
 .../FlinkStreamingPortablePipelineTranslator.java  | 24 +++++--------
 .../FlinkDefaultExecutableStageContext.java        |  5 ++-
 .../functions/FlinkExecutableStageContext.java     | 12 +++++--
 .../functions/FlinkExecutableStageFunction.java    | 16 +++++++--
 .../streaming/ExecutableStageDoFnOperatorTest.java |  6 ++--
 .../control/DefaultJobBundleFactory.java           | 22 ++++++------
 .../fnexecution/state/GrpcStateService.java        |  9 +++++
 .../beam/sdk/options/PortablePipelineOptions.java  | 17 ++++++++-
 14 files changed, 142 insertions(+), 68 deletions(-)