You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2018/07/03 22:01:36 UTC
[beam] 01/01: Merge pull request #5838: Read worker harness image
name from pipeline option for portable runners
This is an automated email from the ASF dual-hosted git repository.
jkff pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 4a92d28967a1c3fbe4719d8599bdde7b9ff2e31f
Merge: d667097 19c92df
Author: Eugene Kirpichov <ek...@gmail.com>
AuthorDate: Tue Jul 3 15:01:31 2018 -0700
Merge pull request #5838: Read worker harness image name from pipeline option for portable runners
Read worker harness image name from pipeline option for portable runners
.../core/construction/CombineTranslation.java | 5 ++---
.../CreatePCollectionViewTranslation.java | 5 ++++-
.../beam/runners/core/construction/Environments.java | 7 +++++++
.../construction/ExecutableStageTranslation.java | 3 ++-
.../runners/core/construction/ParDoTranslation.java | 14 ++++++++------
.../core/construction/PipelineTranslation.java | 2 +-
.../runners/core/construction/ReadTranslation.java | 11 ++++++-----
.../runners/core/construction/SdkComponents.java | 16 ++++++++++++++++
.../core/construction/TestStreamTranslation.java | 2 +-
.../core/construction/WindowIntoTranslation.java | 4 ++--
.../construction/WindowingStrategyTranslation.java | 20 +++++++-------------
.../core/construction/WriteFilesTranslation.java | 5 +++--
.../core/construction/CoderTranslationTest.java | 8 +++++---
.../core/construction/CombineTranslationTest.java | 4 ++++
.../CreatePCollectionViewTranslationTest.java | 3 +++
.../runners/core/construction/EnvironmentsTest.java | 6 ++++++
.../construction/PCollectionTranslationTest.java | 3 +++
.../construction/PCollectionViewTranslationTest.java | 9 +++++++--
.../core/construction/PTransformTranslationTest.java | 2 +-
.../core/construction/ParDoTranslationTest.java | 4 ++++
.../core/construction/PipelineTranslationTest.java | 2 +-
.../core/construction/ReadTranslationTest.java | 9 +++++++--
.../core/construction/RehydratedComponentsTest.java | 4 ++++
.../runners/core/construction/SdkComponentsTest.java | 9 ++++++++-
.../core/construction/TestStreamTranslationTest.java | 3 +++
.../core/construction/WindowIntoTranslationTest.java | 2 ++
.../WindowingStrategyTranslationTest.java | 6 +++++-
.../core/construction/WriteFilesTranslationTest.java | 5 ++++-
.../BundleFactoryOutputReceiverFactoryTest.java | 2 ++
.../portable/GroupByKeyOnlyEvaluatorFactoryTest.java | 2 ++
.../runners/dataflow/DataflowPipelineTranslator.java | 7 ++++++-
.../wire/LengthPrefixUnknownCodersTest.java | 2 ++
.../src/main/java/org/apache/beam/sdk/Pipeline.java | 5 +++++
.../beam/sdk/options/PortablePipelineOptions.java | 7 +++++++
.../org/apache/beam/sdk/testing/TestPipeline.java | 1 +
.../beam/fn/harness/AssignWindowsRunnerTest.java | 14 ++++++++++----
.../apache/beam/fn/harness/CombineRunnersTest.java | 2 +-
.../apache/beam/fn/harness/FnApiDoFnRunnerTest.java | 6 +++---
.../beam/fn/harness/WindowMappingFnRunnerTest.java | 5 ++++-
39 files changed, 169 insertions(+), 57 deletions(-)