This closes #2549
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fac4f3e3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fac4f3e3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fac4f3e3 Branch: refs/heads/master Commit: fac4f3e3c937a76d6ca92ca6f73f8df9928ae94c Parents: e556858 88513db Author: Ismaël MejÃa <ieme...@apache.org> Authored: Tue Apr 18 16:12:58 2017 +0200 Committer: Ismaël MejÃa <ieme...@apache.org> Committed: Tue Apr 18 16:12:58 2017 +0200 ---------------------------------------------------------------------- runners/flink/pom.xml | 45 +++++--- runners/flink/runner/pom.xml | 109 +++++++++++-------- .../flink/FlinkDetachedRunnerResult.java | 3 +- .../types/EncodedValueTypeInformation.java | 9 -- .../streaming/SingletonKeyedWorkItem.java | 2 - .../streaming/SingletonKeyedWorkItemCoder.java | 2 - .../wrappers/streaming/WindowDoFnOperator.java | 3 - .../beam/runners/flink/PipelineOptionsTest.java | 2 +- 8 files changed, 95 insertions(+), 80 deletions(-) ----------------------------------------------------------------------