[FLINK-7438] [scala] Remove unused import

These classes imported the org.apache.flink.util.OutputTag class, which was however not used since a scala OutputTag class exists in the same package. This caused the compiler to throw warnings as the import was overshadowed by the package local class. This closes apache#4570.
deepfield · Sep 28, 2017 · 40fbe66 · 40fbe66
1 parent 426137f
commit 40fbe66
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...reaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala b/...reaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala
@@ -30,7 +30,7 @@ import org.apache.flink.streaming.api.windowing.evictors.Evictor
 import org.apache.flink.streaming.api.windowing.time.Time
 import org.apache.flink.streaming.api.windowing.triggers.Trigger
 import org.apache.flink.streaming.api.windowing.windows.Window
-import org.apache.flink.util.{Collector, OutputTag}
+import org.apache.flink.util.Collector
 import org.apache.flink.util.Preconditions.checkNotNull
 
 /**

diff --git a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
@@ -39,7 +39,7 @@ import org.apache.flink.streaming.api.windowing.assigners._
 import org.apache.flink.streaming.api.windowing.time.Time
 import org.apache.flink.streaming.api.windowing.windows.{GlobalWindow, TimeWindow, Window}
 import org.apache.flink.streaming.util.serialization.SerializationSchema
-import org.apache.flink.util.{Collector, OutputTag}
+import org.apache.flink.util.Collector
 
 import scala.collection.JavaConverters._
 

diff --git a/...-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala b/...-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala
@@ -30,7 +30,7 @@ import org.apache.flink.streaming.api.windowing.evictors.Evictor
 import org.apache.flink.streaming.api.windowing.time.Time
 import org.apache.flink.streaming.api.windowing.triggers.Trigger
 import org.apache.flink.streaming.api.windowing.windows.Window
-import org.apache.flink.util.{Collector, OutputTag}
+import org.apache.flink.util.Collector
 
 /**
  * A [[WindowedStream]] represents a data stream where elements are grouped by