[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 <[email protected]> Authored: Wed Oct 11 16:12:49 2017 -0700 Committer: Luke Cwik <[email protected]> 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(-) ----------------------------------------------------------------------
