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