You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/09/28 12:44:04 UTC
flink git commit: [FLINK-7438] [scala] Remove unused import
Repository: flink
Updated Branches:
refs/heads/master 426137f51 -> 40fbe662c
[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.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/40fbe662
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/40fbe662
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/40fbe662
Branch: refs/heads/master
Commit: 40fbe662cf612877dd7fec1762c318ff7bdadf43
Parents: 426137f
Author: yew1eb <ye...@gmail.com>
Authored: Tue Sep 26 23:45:18 2017 +0800
Committer: zentol <ch...@apache.org>
Committed: Thu Sep 28 14:41:45 2017 +0200
----------------------------------------------------------------------
.../org/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(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/40fbe662/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala
----------------------------------------------------------------------
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 bbdcf4a..f21c0fb 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
/**
http://git-wip-us.apache.org/repos/asf/flink/blob/40fbe662/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala
----------------------------------------------------------------------
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 63a2d5d..f6fd074 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._
http://git-wip-us.apache.org/repos/asf/flink/blob/40fbe662/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala
----------------------------------------------------------------------
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 0f8a6e0..337e5ce 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