You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/01/24 10:34:08 UTC
[flink] 03/03: [hotfix] Fix checkstyle violations in
AkkaRpcActorTest
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 35779f22b1921646d7a858156fcafeb8238974f3
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Thu Jan 24 09:00:07 2019 +0100
[hotfix] Fix checkstyle violations in AkkaRpcActorTest
---
.../org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java
index 040e949..27eca97 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java
@@ -51,6 +51,9 @@ import static org.junit.Assert.assertThat;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
+/**
+ * Tests for the {@link AkkaRpcActor}.
+ */
public class AkkaRpcActorTest extends TestLogger {
// ------------------------------------------------------------------------
@@ -61,7 +64,6 @@ public class AkkaRpcActorTest extends TestLogger {
private static AkkaRpcService akkaRpcService;
-
@BeforeClass
public static void setup() {
akkaRpcService = new TestingRpcService();
@@ -304,7 +306,7 @@ public class AkkaRpcActorTest extends TestLogger {
static class DummyRpcEndpoint extends TestRpcEndpoint implements DummyRpcGateway {
- private volatile int _foobar = 42;
+ private volatile int foobar = 42;
protected DummyRpcEndpoint(RpcService rpcService) {
super(rpcService);
@@ -312,11 +314,11 @@ public class AkkaRpcActorTest extends TestLogger {
@Override
public CompletableFuture<Integer> foobar() {
- return CompletableFuture.completedFuture(_foobar);
+ return CompletableFuture.completedFuture(foobar);
}
public void setFoobar(int value) {
- _foobar = value;
+ foobar = value;
}
}