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/03/25 13:40:48 UTC
[beam] branch master updated (af8559d -> d309c1b)
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 af8559d Merge pull request #11200: [BEAM-9573] Correct computing of watermark hold for timer output timestamp
add 8babe39 [BEAM-9420] Configurable timeout for blocking kafka API call(s)
new d309c1b Merge pull request #11099: [BEAM-9420] Configurable timeout for blocking kafka API call(s)
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 8 ++++
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 48 ++++++++++++++++------
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 40 ++++++++++++++++--
3 files changed, 80 insertions(+), 16 deletions(-)
[beam] 01/01: Merge pull request #11099: [BEAM-9420] Configurable
timeout for blocking kafka API call(s)
Posted by ar...@apache.org.
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 d309c1b7c39ba78aa0cbd5cad9cc7a256e3caa9f
Merge: af8559d 8babe39
Author: Alexey Romanenko <33...@users.noreply.github.com>
AuthorDate: Wed Mar 25 14:40:30 2020 +0100
Merge pull request #11099: [BEAM-9420] Configurable timeout for blocking kafka API call(s)
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 8 ++++
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 48 ++++++++++++++++------
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 40 ++++++++++++++++--
3 files changed, 80 insertions(+), 16 deletions(-)