[2/3] beam git commit: Handle Errors in the DirectRunner

2017-05-09 Thread tgroh
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

[2/3] beam git commit: Handle Errors in the DirectRunner

2017-05-09 Thread dhalperi
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