You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ie...@apache.org on 2018/08/13 20:35:09 UTC

[beam] 01/01: Merge pull request #6178: [BEAM-5063] Fix Watermark does not progress for low traffic streams

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

iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit faf631a592121bacd0b1c737fe4d03659b0caec1
Merge: 69263c9 4ebc33b
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Mon Aug 13 22:35:03 2018 +0200

    Merge pull request #6178: [BEAM-5063] Fix Watermark does not progress for low traffic streams

 .../org/apache/beam/sdk/util/MovingFunction.java   |   8 +-
 .../apache/beam/sdk/util/MovingFunctionTest.java   |   8 ++
 .../apache/beam/sdk/io/kinesis/KinesisReader.java  |  51 ++------
 .../beam/sdk/io/kinesis/KinesisWatermark.java      | 116 +++++++++++++++++
 .../beam/sdk/io/kinesis/KinesisReaderTest.java     | 125 +++++--------------
 .../beam/sdk/io/kinesis/KinesisWatermarkTest.java  | 138 +++++++++++++++++++++
 6 files changed, 306 insertions(+), 140 deletions(-)