This closes #1093
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6b5ff4c4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6b5ff4c4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6b5ff4c4 Branch: refs/heads/master Commit: 6b5ff4c4aad5e4d1419b1a147153b0f8d72324ae Parents: a2c342c 76434df Author: Maximilian Michels <m...@apache.org> Authored: Tue Oct 18 16:59:58 2016 +0200 Committer: Maximilian Michels <m...@apache.org> Committed: Tue Oct 18 16:59:58 2016 +0200 ---------------------------------------------------------------------- .../flink/FlinkDetachedRunnerResult.java | 76 ++++++++++++++++++++ .../apache/beam/runners/flink/FlinkRunner.java | 9 ++- .../beam/runners/flink/FlinkRunnerResult.java | 11 +-- .../beam/runners/flink/TestFlinkRunner.java | 9 ++- 4 files changed, 91 insertions(+), 14 deletions(-) ----------------------------------------------------------------------
