Repository: incubator-beam Updated Branches: refs/heads/master 66faf74d0 -> 8daa8b519
Remove Leftover Sysout Printing in Flink Runner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d8f3da6f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d8f3da6f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d8f3da6f Branch: refs/heads/master Commit: d8f3da6f42713ee02e49ee7bbdd7bc79c88dd37b Parents: 66faf74 Author: Alexey Diomin <diomi...@gmail.com> Authored: Thu Nov 10 16:57:43 2016 +0400 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Thu Nov 10 15:47:15 2016 +0100 ---------------------------------------------------------------------- .../flink/translation/FlinkStreamingTransformTranslators.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/d8f3da6f/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingTransformTranslators.java ---------------------------------------------------------------------- diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingTransformTranslators.java b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingTransformTranslators.java index 069162f..a3e8a49 100644 --- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingTransformTranslators.java +++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkStreamingTransformTranslators.java @@ -536,9 +536,7 @@ public class FlinkStreamingTransformTranslators { unionOutputStream.flatMap(new FlatMapFunction<RawUnionValue, Object>() { @Override public void flatMap(RawUnionValue value, Collector<Object> out) throws Exception { - System.out.println("FILTERING: " + value); if (value.getUnionTag() == outputTag) { - System.out.println("EMITTING VALUE: " + value); out.collect(value.getValue()); } }
