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 2018/11/19 16:04:26 UTC
[beam] branch master updated (e4bb78a -> 50f623c)
This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from e4bb78a Merge pull request #6957 from echauchot/BEAM-5969-new-nexmark-query
add b032f5d [BEAM-4681] Add support for portable timers in Flink batch mode
add 525d7e5 [BEAM-4681] Use CoderUtils to decode key
add a3a96bc [BEAM-867] Support set/delete of timers by ID in FlinkRunner
add 53e1c98 [BEAM-4681] Enable Java portable ValidatesRunner timer tests
add 604c5ff [BEAM-4681] Enable Python ValidatesRunner timer tests
add b752ad5 [BEAM-4681] Simplify by replacing the two timer keys with a single one
new 50f623c Merge pull request #7008: [BEAM-4681] Add support for portable timers in Flink batch mode
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 -
.../FlinkBatchPortablePipelineTranslator.java | 19 +-
.../functions/FlinkExecutableStageFunction.java | 254 ++++++++++++++++++---
.../wrappers/streaming/DoFnOperator.java | 68 +++++-
.../streaming/ExecutableStageDoFnOperator.java | 49 ++--
.../runners/flink/PortableTimersExecutionTest.java | 3 +-
.../runners/flink/streaming/DoFnOperatorTest.java | 13 +-
.../FlinkExecutableStageFunctionTest.java | 48 ++--
.../runners/portability/flink_runner_test.py | 4 -
9 files changed, 349 insertions(+), 111 deletions(-)
[beam] 01/01: Merge pull request #7008: [BEAM-4681] Add support for
portable timers in Flink batch mode
Posted by mx...@apache.org.
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 50f623c023f423aab1336aee136c36ef3c82d1ca
Merge: e4bb78a b752ad5
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Mon Nov 19 17:04:19 2018 +0100
Merge pull request #7008: [BEAM-4681] Add support for portable timers in Flink batch mode
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 -
.../FlinkBatchPortablePipelineTranslator.java | 19 +-
.../functions/FlinkExecutableStageFunction.java | 254 ++++++++++++++++++---
.../wrappers/streaming/DoFnOperator.java | 68 +++++-
.../streaming/ExecutableStageDoFnOperator.java | 49 ++--
.../runners/flink/PortableTimersExecutionTest.java | 3 +-
.../runners/flink/streaming/DoFnOperatorTest.java | 13 +-
.../FlinkExecutableStageFunctionTest.java | 48 ++--
.../runners/portability/flink_runner_test.py | 4 -
9 files changed, 349 insertions(+), 111 deletions(-)