This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 207f34e Merge pull request #8715: [BEAM-7442][BEAM-5650] Read
sequentially from bounded sources in UnboundedSourceWrapper
add fb51440 [BEAM-7357] KinesisIO: fix too many checks that writing
stream exists.
add 14879ed Merge pull request #8730: [BEAM-7357] KinesisIO: fix too many
checks that writing stream exists.
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/beam/sdk/io/kinesis/KinesisIO.java | 13 ++++++++-----
.../apache/beam/sdk/io/kinesis/KinesisMockWriteTest.java | 16 +++++++---------
2 files changed, 15 insertions(+), 14 deletions(-)
