This is an automated email from the ASF dual-hosted git repository.

aljoscha pushed a change to branch master
in repository

    from 51b793a  Merge pull request #4723: [BEAM-3317] Use fixed system time 
for KinesisReaderTest
     new 50c6d93  Make parameter of DoFnRunners.lateDataDroppingRunner() more 
     new c40868f  Allow overriding DoFnRunners in subclasses of Flink 
     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 
     new d15979f  [BEAM-2140] Don't use StatefulDoFnRunner when running SDF in 
     new 4ec4644  Make ProcessFnRunner constructor public
     new 74ac703  [BEAM-2140] Use ProcessFnRunner in DoFnRunner for executing 
     new c920a39  [BEAM-2140] Enable SDF tests for Flink Streaming Runner
     new 6ba3fc1  [BEAM-2140] Enable SDF tests in gradle for Flink Streaming 
     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/  |   4 +-
 .../apache/beam/runners/core/  |   2 +-
 runners/flink/build.gradle                         |  24 ++--
 runners/flink/pom.xml                              |   1 -
 .../beam/runners/flink/   |  12 ++
 .../flink/  |  35 +++++-
 .../apache/beam/runners/flink/ |   1 +
 .../wrappers/streaming/           | 127 +++++++++++++--------
 .../wrappers/streaming/ |  16 +++
 .../wrappers/streaming/     |  18 +++
 .../streaming/io/         |  28 +++++
 .../streaming/io/       |  56 ++++-----
 12 files changed, 234 insertions(+), 90 deletions(-)

To stop receiving notification emails like this one, please contact

Reply via email to