You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2016/11/10 14:48:24 UTC
[1/2] incubator-beam git commit: Remove Leftover Sysout Printing in
Flink Runner
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 <di...@gmail.com>
Authored: Thu Nov 10 16:57:43 2016 +0400
Committer: Aljoscha Krettek <al...@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());
}
}
[2/2] incubator-beam git commit: This closes #1333
Posted by al...@apache.org.
This closes #1333
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8daa8b51
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8daa8b51
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8daa8b51
Branch: refs/heads/master
Commit: 8daa8b519fe5b2f3286c3f592a26841a374c057c
Parents: 66faf74 d8f3da6
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Thu Nov 10 15:47:59 2016 +0100
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Thu Nov 10 15:47:59 2016 +0100
----------------------------------------------------------------------
.../flink/translation/FlinkStreamingTransformTranslators.java | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------