This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit c4786e8519c6394ffccadd661c8462108c70cdc6 Author: Till Rohrmann <trohrm...@apache.org> AuthorDate: Mon Mar 4 10:43:00 2019 +0100 [hotfix] Fix checkstyle violations in ZooKeeperLeaderRetrievalTest --- .../leaderelection/ZooKeeperLeaderRetrievalTest.java | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderRetrievalTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderRetrievalTest.java index 0282a4f..42c1eca 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderRetrievalTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderRetrievalTest.java @@ -18,9 +18,6 @@ package org.apache.flink.runtime.leaderelection; -import org.apache.curator.framework.CuratorFramework; -import org.apache.curator.test.TestingServer; - import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.HighAvailabilityOptions; import org.apache.flink.runtime.blob.VoidBlobStore; @@ -35,12 +32,12 @@ import org.apache.flink.runtime.util.LeaderRetrievalUtils; import org.apache.flink.runtime.util.ZooKeeperUtils; import org.apache.flink.util.TestLogger; +import org.apache.curator.framework.CuratorFramework; +import org.apache.curator.test.TestingServer; import org.junit.After; import org.junit.Before; import org.junit.Test; -import scala.concurrent.duration.FiniteDuration; - import java.io.IOException; import java.net.InetAddress; import java.net.InetSocketAddress; @@ -50,8 +47,13 @@ import java.net.SocketAddress; import java.net.UnknownHostException; import java.util.concurrent.TimeUnit; +import scala.concurrent.duration.FiniteDuration; + import static org.junit.Assert.assertEquals; +/** + * Tests for the ZooKeeper based leader election and retrieval. + */ public class ZooKeeperLeaderRetrievalTest extends TestLogger{ private TestingServer testingServer; @@ -79,7 +81,7 @@ public class ZooKeeperLeaderRetrievalTest extends TestLogger{ @After public void after() throws Exception { - if(testingServer != null) { + if (testingServer != null) { testingServer.stop(); testingServer = null;