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 <m...@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(-)