beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
Subject [beam] branch master updated (51b793a -> 0259636)
Date Fri, 23 Feb 2018 11:00:21 GMT
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 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/  |   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

View raw message