You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2018/05/28 11:24:38 UTC
flink git commit: [hotfix] Removed unused scala imports.
Repository: flink
Updated Branches:
refs/heads/master a5fa09312 -> a47f51ffe
[hotfix] Removed unused scala imports.
This closes #5820.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a47f51ff
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a47f51ff
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a47f51ff
Branch: refs/heads/master
Commit: a47f51ffeaaf51eafb003f14d0bc2fed45d36648
Parents: a5fa093
Author: Bowen Li <bo...@gmail.com>
Authored: Thu Apr 5 00:52:37 2018 -0700
Committer: Stefan Richter <s....@data-artisans.com>
Committed: Mon May 28 13:24:00 2018 +0200
----------------------------------------------------------------------
.../flink/streaming/api/scala/async/JavaResultFutureWrapper.scala | 1 -
.../apache/flink/streaming/api/scala/BroadcastStateITCase.scala | 2 +-
.../org/apache/flink/streaming/api/scala/SlotAllocationTest.scala | 2 +-
.../apache/flink/streaming/api/scala/WindowFunctionITCase.scala | 2 +-
4 files changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a47f51ff/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/JavaResultFutureWrapper.scala
----------------------------------------------------------------------
diff --git a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/JavaResultFutureWrapper.scala b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/JavaResultFutureWrapper.scala
index 7680b89..1e2f18a 100644
--- a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/JavaResultFutureWrapper.scala
+++ b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/JavaResultFutureWrapper.scala
@@ -20,7 +20,6 @@ package org.apache.flink.streaming.api.scala.async
import org.apache.flink.annotation.Internal
import org.apache.flink.streaming.api.functions.async
-import org.apache.flink.streaming.api.functions.async.ResultFuture
import scala.collection.JavaConverters._
http://git-wip-us.apache.org/repos/asf/flink/blob/a47f51ff/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/BroadcastStateITCase.scala
----------------------------------------------------------------------
diff --git a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/BroadcastStateITCase.scala b/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/BroadcastStateITCase.scala
index f1bfced..142133c 100644
--- a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/BroadcastStateITCase.scala
+++ b/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/BroadcastStateITCase.scala
@@ -28,7 +28,7 @@ import org.apache.flink.streaming.api.watermark.Watermark
import org.apache.flink.test.util.AbstractTestBase
import org.apache.flink.util.Collector
import org.junit.Assert.assertEquals
-import org.junit.{Test}
+import org.junit.Test
/**
* ITCase for the [[org.apache.flink.api.common.state.BroadcastState]].
http://git-wip-us.apache.org/repos/asf/flink/blob/a47f51ff/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/SlotAllocationTest.scala
----------------------------------------------------------------------
diff --git a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/SlotAllocationTest.scala b/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/SlotAllocationTest.scala
index 63ea0ea..2f53665 100644
--- a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/SlotAllocationTest.scala
+++ b/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/SlotAllocationTest.scala
@@ -18,7 +18,7 @@
package org.apache.flink.streaming.api.scala
import org.apache.flink.api.common.functions.FilterFunction
-import org.apache.flink.runtime.jobgraph.{JobVertex, JobGraph}
+import org.apache.flink.runtime.jobgraph.JobGraph
import org.junit.Assert._
import org.junit.Test
http://git-wip-us.apache.org/repos/asf/flink/blob/a47f51ff/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/WindowFunctionITCase.scala
----------------------------------------------------------------------
diff --git a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/WindowFunctionITCase.scala b/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/WindowFunctionITCase.scala
index 5a5f814..ce5f09e 100644
--- a/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/WindowFunctionITCase.scala
+++ b/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/WindowFunctionITCase.scala
@@ -32,7 +32,7 @@ import org.apache.flink.streaming.api.windowing.time.Time
import org.apache.flink.streaming.api.windowing.windows.TimeWindow
import org.apache.flink.util.TestLogger
import org.junit.Assert._
-import org.junit.{Ignore, Test}
+import org.junit.Test
import scala.collection.mutable