This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 51b793a Merge pull request #4723: [BEAM-3317] Use fixed system time for KinesisReaderTest new 50c6d93 Make parameter of DoFnRunners.lateDataDroppingRunner() more specific new c40868f Allow overriding DoFnRunners in subclasses of Flink DoFnOperator new 4029e23f Invoke finishBundle() before teardown() in DoFnOperator new 2e0b192 [BEAM-2140] Ignore event-time timers in SplittableDoFnOperator new 3eecb38 [BEAM-2140] Block DoFnOperator.close() if we have pending timers new d15979f [BEAM-2140] Don't use StatefulDoFnRunner when running SDF in FlinkRunner new 4ec4644 Make ProcessFnRunner constructor public new 74ac703 [BEAM-2140] Use ProcessFnRunner in DoFnRunner for executing SDF new c920a39 [BEAM-2140] Enable SDF tests for Flink Streaming Runner new 6ba3fc1 [BEAM-2140] Enable SDF tests in gradle for Flink Streaming Runner new 6148a6d [BEAM-3727] Never shutdown sources in Flink Streaming execution mode new 0259636 Merge pull request #4639: [BEAM-2140] Fix SplittableDoFn ValidatesRunner tests in Flink Streaming Runner The 12 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/runners/core/DoFnRunners.java | 4 +- .../apache/beam/runners/core/ProcessFnRunner.java | 2 +- runners/flink/build.gradle | 24 ++-- runners/flink/pom.xml | 1 - .../beam/runners/flink/FlinkPipelineOptions.java | 12 ++ .../flink/FlinkStreamingTransformTranslators.java | 35 +++++- .../apache/beam/runners/flink/TestFlinkRunner.java | 1 + .../wrappers/streaming/DoFnOperator.java | 127 +++++++++++++-------- .../wrappers/streaming/SplittableDoFnOperator.java | 16 +++ .../wrappers/streaming/WindowDoFnOperator.java | 18 +++ .../streaming/io/BoundedSourceWrapper.java | 28 +++++ .../streaming/io/UnboundedSourceWrapper.java | 56 ++++----- 12 files changed, 234 insertions(+), 90 deletions(-) -- To stop receiving notification emails like this one, please contact aljos...@apache.org.