This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9068fbe4f38b8866148986fa48e14d8d2e7e7100
Author: zentol <ches...@apache.org>
AuthorDate: Mon Aug 27 11:06:42 2018 +0200
[FLINK-10207] Fix newly discovered checkstyle violations
---
.../src/test/java/org/apache/flink/client/program/ClientTest.java | 6 +++---
.../flink/streaming/tests/StatefulStreamJobUpgradeTestProgram.java | 6 +++---
.../org/apache/flink/api/java/utils/AbstractParameterToolTest.java | 4 ++--
.../webmonitor/retriever/impl/AkkaJobManagerRetrieverTest.java | 4 ++--
.../org/apache/flink/yarn/YarnTaskManagerRunnerFactoryTest.java | 6 +++---
5 files changed, 13 insertions(+), 13 deletions(-)
diff --git
a/flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java
b/flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java
index ec9cfc5..a83f29c 100644
---
a/flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java
+++
b/flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java
@@ -60,6 +60,9 @@ import java.net.URL;
import java.util.Collections;
import java.util.UUID;
+import scala.concurrent.Await;
+import scala.concurrent.duration.Duration;
+
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.fail;
@@ -67,9 +70,6 @@ import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
-import scala.concurrent.Await;
-import scala.concurrent.duration.Duration;
-
/**
* Simple and maybe stupid test to check the {@link ClusterClient} class.
*/
diff --git
a/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/src/main/java/org/apache/flink/streaming/tests/StatefulStreamJobUpgradeTestProgram.java
b/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/src/main/java/org/apache/flink/streaming/tests/StatefulStreamJobUpgradeTestProgram.java
index 4f77f95..3d6c583 100644
---
a/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/src/main/java/org/apache/flink/streaming/tests/StatefulStreamJobUpgradeTestProgram.java
+++
b/flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/src/main/java/org/apache/flink/streaming/tests/StatefulStreamJobUpgradeTestProgram.java
@@ -29,15 +29,15 @@ import
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.sink.PrintSinkFunction;
import org.apache.flink.streaming.tests.artificialstate.ComplexPayload;
+import java.util.Collections;
+import java.util.List;
+
import static
org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory.createArtificialKeyedStateMapper;
import static
org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory.createEventSource;
import static
org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory.createSemanticsCheckMapper;
import static
org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory.createTimestampExtractor;
import static
org.apache.flink.streaming.tests.DataStreamAllroundTestJobFactory.setupEnvironment;
-import java.util.Collections;
-import java.util.List;
-
/**
* Test upgrade of generic stateful job for Flink's DataStream API operators
and primitives.
*
diff --git
a/flink-java/src/test/java/org/apache/flink/api/java/utils/AbstractParameterToolTest.java
b/flink-java/src/test/java/org/apache/flink/api/java/utils/AbstractParameterToolTest.java
index cd37121..784a50e 100644
---
a/flink-java/src/test/java/org/apache/flink/api/java/utils/AbstractParameterToolTest.java
+++
b/flink-java/src/test/java/org/apache/flink/api/java/utils/AbstractParameterToolTest.java
@@ -26,12 +26,12 @@ import org.junit.Assert;
import org.junit.Rule;
import org.junit.rules.TemporaryFolder;
-import static org.junit.Assert.fail;
-
import java.io.FileInputStream;
import java.io.IOException;
import java.util.Properties;
+import static org.junit.Assert.fail;
+
/**
* Base class for tests for {@link ParameterTool}.
*/
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/retriever/impl/AkkaJobManagerRetrieverTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/retriever/impl/AkkaJobManagerRetrieverTest.java
index 5314550..35fa7b8 100644
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/retriever/impl/AkkaJobManagerRetrieverTest.java
+++
b/flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/retriever/impl/AkkaJobManagerRetrieverTest.java
@@ -39,11 +39,11 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
+import scala.concurrent.Await;
+
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
-import scala.concurrent.Await;
-
/**
* Test for the {@link AkkaJobManagerRetriever}.
*/
diff --git
a/flink-yarn/src/test/java/org/apache/flink/yarn/YarnTaskManagerRunnerFactoryTest.java
b/flink-yarn/src/test/java/org/apache/flink/yarn/YarnTaskManagerRunnerFactoryTest.java
index 7f518f1..f23b256 100644
---
a/flink-yarn/src/test/java/org/apache/flink/yarn/YarnTaskManagerRunnerFactoryTest.java
+++
b/flink-yarn/src/test/java/org/apache/flink/yarn/YarnTaskManagerRunnerFactoryTest.java
@@ -27,9 +27,6 @@ import
org.apache.flink.runtime.security.modules.SecurityModule;
import org.apache.hadoop.yarn.api.ApplicationConstants;
import org.junit.Test;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.fail;
-
import java.io.IOException;
import java.nio.file.Paths;
import java.util.HashMap;
@@ -37,6 +34,9 @@ import java.util.List;
import java.util.Map;
import java.util.Optional;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.fail;
+
/**
* Tests for {@link YarnTaskManagerRunnerFactory}.
*/
