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

Posted to commits@beam.apache.org by mx...@apache.org on 2018/11/06 20:02:11 UTC

[beam] 01/01: Merge pull request #6946: [BEAM-5971] Prevent unwanted shutdown of UnboundedSourceWrapper

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

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

commit b71eb72c94ba5b4091a1cbc5439bb856124c3aee
Merge: b70fea2 a64fda6
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Tue Nov 6 21:01:56 2018 +0100

    Merge pull request #6946: [BEAM-5971] Prevent unwanted shutdown of UnboundedSourceWrapper

 .../streaming/io/UnboundedSourceWrapper.java       | 22 ++++----
 .../streaming/UnboundedSourceWrapperTest.java      | 60 +++++++++++++++++++++-
 2 files changed, 71 insertions(+), 11 deletions(-)