This closes #1311
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/66faf74d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/66faf74d Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/66faf74d Branch: refs/heads/master Commit: 66faf74d084e4eba982063c9ca81673b0cfece4b Parents: ef750c0 a609a19 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Thu Nov 10 10:37:46 2016 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Thu Nov 10 10:37:46 2016 +0100 ---------------------------------------------------------------------- .../org/apache/beam/runners/flink/examples/TFIDF.java | 11 +++++++++-- runners/flink/pom.xml | 8 -------- .../java/org/apache/beam/runners/flink/FlinkRunner.java | 4 ++-- .../translation/FlinkStreamingTransformTranslators.java | 2 -- .../wrappers/SerializableFnAggregatorWrapper.java | 7 +++++++ .../wrappers/streaming/WindowDoFnOperator.java | 2 +- .../wrappers/streaming/io/UnboundedSocketSource.java | 5 +---- .../wrappers/streaming/io/UnboundedSourceWrapper.java | 3 ++- 8 files changed, 22 insertions(+), 20 deletions(-) ----------------------------------------------------------------------
