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

Posted to commits@beam.apache.org by ar...@apache.org on 2020/05/11 11:47:47 UTC

[beam] 01/01: Merge pull request #11377: [BEAM-9439] Return split instead of total backlog size

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

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

commit 8fdc9ceb55ced2826a973ad283af3bc89440d99e
Merge: 5134cde 1e182c6
Author: Alexey Romanenko <33...@users.noreply.github.com>
AuthorDate: Mon May 11 13:47:23 2020 +0200

    Merge pull request #11377: [BEAM-9439] Return split instead of total backlog size

 .../apache/beam/sdk/io/kinesis/KinesisReader.java  | 47 ++++++++++++++++------
 .../beam/sdk/io/kinesis/ShardReadersPool.java      | 17 ++++++--
 .../beam/sdk/io/kinesis/ShardRecordsIterator.java  | 38 +++++++++++------
 .../beam/sdk/io/kinesis/KinesisReaderTest.java     | 35 ++++++++--------
 .../beam/sdk/io/kinesis/ShardReadersPoolTest.java  | 28 ++++++++++---
 .../sdk/io/kinesis/ShardRecordsIteratorTest.java   | 30 ++++++++++++--
 6 files changed, 140 insertions(+), 55 deletions(-)