Skip to content

Commit

Permalink
[FLINK-10207] Fix newly discovered checkstyle violations
Browse files Browse the repository at this point in the history
  • Loading branch information
zentol committed Aug 29, 2018
1 parent ebd7a04 commit 9068fbe
Show file tree
Hide file tree
Showing 5 changed files with 13 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -60,16 +60,16 @@
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;
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.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,15 +29,15 @@
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.
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,12 +26,12 @@
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}.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,11 +39,11 @@
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}.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,16 +27,16 @@
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;
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}.
*/
Expand Down

0 comments on commit 9068fbe

Please sign in to comment.