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
[email protected].
