Handle Errors in the DirectRunner
When a worker dies because of an error, propagate that error and fail
the Pipeline.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/441f5d36
Tree: http://git-wip-us.apache.org/repos/asf/beam/tr
Handle Errors in the DirectRunner
When a worker dies because of an error, propagate that error and fail
the Pipeline.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f03c04a7
Tree: http://git-wip-us.apache.org/repos/asf/beam/tr