HBASE-22304 Fixed remaining Checkstyle issues in hbase-endpoint
This commit is contained in:
parent
e39f7dc930
commit
25ea5fdede
|
@ -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);
|
||||
|
|
Loading…
Reference in New Issue