From 3f5b7b5ae5187a4a47949bf85af6f6d26df26414 Mon Sep 17 00:00:00 2001
From: Alexey Diomin <diominay@gmail.com>
Date: Thu, 10 Nov 2016 16:57:43 +0400
Subject: [PATCH] remove artefact after implementation sideOutput in flink

---
 .../flink/translation/FlinkStreamingTransformTranslators.java   | 2 --
 1 file changed, 2 deletions(-)

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 069162f58f10..a3e8a49f41a0 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 void translateNode(
             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());
                 }
               }