From 40fbe662cf612877dd7fec1762c318ff7bdadf43 Mon Sep 17 00:00:00 2001 From: yew1eb Date: Tue, 26 Sep 2017 23:45:18 +0800 Subject: [PATCH] [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 #4570. --- .../apache/flink/streaming/api/scala/AllWindowedStream.scala | 2 +- .../scala/org/apache/flink/streaming/api/scala/DataStream.scala | 2 +- .../org/apache/flink/streaming/api/scala/WindowedStream.scala | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala index bbdcf4a9322f2..f21c0fb4840f0 100644 --- a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala +++ b/flink-streaming-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 index 63a2d5d37bc00..f6fd074bd2e05 100644 --- 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/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala index 0f8a6e0f35877..337e5ce036ff6 100644 --- a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala +++ b/flink-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