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 2019/06/28 23:07:12 UTC

[beam] 03/03: Merge pull request #8955: [BEAM-7589] Use only one KinesisProducer instance per JVM

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 69f5b7ec58af2d1c57c33a7726b2a223b4eaaf4e
Merge: 6786afd b81025c
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Sat Jun 29 01:04:45 2019 +0200

    Merge pull request #8955: [BEAM-7589] Use only one KinesisProducer instance per JVM

 sdks/java/io/kinesis/build.gradle                  |   1 +
 .../org/apache/beam/sdk/io/kinesis/KinesisIO.java  | 144 ++++++++++-----------
 .../apache/beam/sdk/io/kinesis/KinesisIOIT.java    | 124 ++++++++++--------
 .../beam/sdk/io/kinesis/KinesisMockWriteTest.java  |  20 ++-
 .../beam/sdk/io/kinesis/KinesisProducerMock.java   |  39 +++---
 .../beam/sdk/io/kinesis/KinesisTestOptions.java    |  12 ++
 6 files changed, 181 insertions(+), 159 deletions(-)