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(-)