You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/10/11 23:12:58 UTC
[2/2] beam git commit: [BEAM-3016] Fix blocking issue within run()
when channel terminates while blocking within DirectStreamObserver.
[BEAM-3016] Fix blocking issue within run() when channel terminates while blocking within DirectStreamObserver.
This closes #3944
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6dd90d89
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6dd90d89
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6dd90d89
Branch: refs/heads/master
Commit: 6dd90d89d3d324c9f9f8cb2b1faf38fe525f0a10
Parents: dc3e2f7 b1a22a8
Author: Luke Cwik <lc...@google.com>
Authored: Wed Oct 11 16:12:49 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Wed Oct 11 16:12:49 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/fn/harness/FnHarness.java | 10 +-
.../fn/harness/logging/BeamFnLoggingClient.java | 139 ++++++++++---------
.../logging/BeamFnLoggingClientTest.java | 117 ++++++++++++++--
3 files changed, 185 insertions(+), 81 deletions(-)
----------------------------------------------------------------------