This is an automated email from the ASF dual-hosted git repository. mxm pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 6df2ef3ec9c835097e79b4441ce47ff09a458894 Merge: a3028ef a7a788c Author: Maximilian Michels <[email protected]> AuthorDate: Fri Sep 7 16:39:46 2018 +0200 Merge pull request #6345 from tweise/flinkExecutableStageContextCleanup .../FlinkBatchPortablePipelineTranslator.java | 5 +-- .../FlinkStreamingPortablePipelineTranslator.java | 2 +- ...ava => FlinkDefaultExecutableStageContext.java} | 38 +++++----------------- .../functions/FlinkExecutableStageContext.java | 4 +-- .../functions/FlinkExecutableStageFunction.java | 18 ++++++++-- .../streaming/ExecutableStageDoFnOperator.java | 6 ++-- .../streaming/ExecutableStageDoFnOperatorTest.java | 3 +- .../control/DockerJobBundleFactory.java | 4 --- 8 files changed, 34 insertions(+), 46 deletions(-)
