This is an automated email from the ASF dual-hosted git repository.
janh pushed a commit to branch branch-2.2
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.2 by this push:
new 511e0b5 HBASE-22304 Fixed remaining Checkstyle issues in
hbase-endpoint
511e0b5 is described below
commit 511e0b5d9b5fb13e7e1ddd930e139b7ed521c935
Author: Jan Hentschel <[email protected]>
AuthorDate: Wed Apr 24 17:14:17 2019 +0200
HBASE-22304 Fixed remaining Checkstyle issues in hbase-endpoint
---
.../hadoop/hbase/coprocessor/TestAsyncCoprocessorEndpoint.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestAsyncCoprocessorEndpoint.java
b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestAsyncCoprocessorEndpoint.java
index 1a68f08..1ea3b1e 100644
---
a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestAsyncCoprocessorEndpoint.java
+++
b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestAsyncCoprocessorEndpoint.java
@@ -81,7 +81,7 @@ public class TestAsyncCoprocessorEndpoint extends
TestAsyncAdminBase {
admin
.<TestRpcServiceProtos.TestProtobufRpcProto.Stub,
TestProtos.EchoResponseProto>
coprocessorService(TestRpcServiceProtos.TestProtobufRpcProto::newStub,
- (s, c, done) -> s.echo(c, request, done)).get();
+ (s, c, done) -> s.echo(c, request, done)).get();
assertEquals("hello", response.getMessage());
}
@@ -92,7 +92,7 @@ public class TestAsyncCoprocessorEndpoint extends
TestAsyncAdminBase {
admin
.<TestRpcServiceProtos.TestProtobufRpcProto.Stub,
TestProtos.EmptyResponseProto>
coprocessorService(TestRpcServiceProtos.TestProtobufRpcProto::newStub,
- (s, c, done) -> s.error(c, emptyRequest, done)).get();
+ (s, c, done) -> s.error(c, emptyRequest, done)).get();
fail("Should have thrown an exception");
} catch (Exception e) {
}
@@ -108,7 +108,7 @@ public class TestAsyncCoprocessorEndpoint extends
TestAsyncAdminBase {
.<DummyRegionServerEndpointProtos.DummyService.Stub,
DummyRegionServerEndpointProtos.DummyResponse>
coprocessorService(
DummyRegionServerEndpointProtos.DummyService::newStub,
- (s, c, done) -> s.dummyCall(c, request, done), serverName).get();
+ (s, c, done) -> s.dummyCall(c, request, done),
serverName).get();
assertEquals(DUMMY_VALUE, response.getValue());
}
@@ -122,7 +122,7 @@ public class TestAsyncCoprocessorEndpoint extends
TestAsyncAdminBase {
.<DummyRegionServerEndpointProtos.DummyService.Stub,
DummyRegionServerEndpointProtos.DummyResponse>
coprocessorService(
DummyRegionServerEndpointProtos.DummyService::newStub,
- (s, c, done) -> s.dummyThrow(c, request, done), serverName).get();
+ (s, c, done) -> s.dummyThrow(c, request, done),
serverName).get();
fail("Should have thrown an exception");
} catch (Exception e) {
assertTrue(e.getCause() instanceof RetriesExhaustedException);