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