You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ms...@apache.org on 2019/03/14 11:32:11 UTC
[hadoop] branch trunk updated: HDDS-1237. Fix test
TestSecureContainerServer.testClientServerRatisGrpc. Contributed by Mukul
Kumar Singh.
This is an automated email from the ASF dual-hosted git repository.
msingh pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 983b78a HDDS-1237. Fix test TestSecureContainerServer.testClientServerRatisGrpc. Contributed by Mukul Kumar Singh.
983b78a is described below
commit 983b78afdc8939d0d2116f23837d958e6b5d9e46
Author: Mukul Kumar Singh <ms...@apache.org>
AuthorDate: Thu Mar 14 16:49:43 2019 +0530
HDDS-1237. Fix test TestSecureContainerServer.testClientServerRatisGrpc. Contributed by Mukul Kumar Singh.
---
.../hadoop/ozone/container/server/TestSecureContainerServer.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/server/TestSecureContainerServer.java b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/server/TestSecureContainerServer.java
index f20feff..3d631cc 100644
--- a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/server/TestSecureContainerServer.java
+++ b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/server/TestSecureContainerServer.java
@@ -30,6 +30,7 @@ import org.apache.hadoop.hdds.scm.XceiverClientRatis;
import org.apache.hadoop.hdds.scm.XceiverClientSpi;
import org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException;
import org.apache.hadoop.hdds.scm.pipeline.Pipeline;
+import org.apache.hadoop.hdds.scm.storage.ContainerProtocolCalls;
import org.apache.hadoop.ozone.OzoneConfigKeys;
import org.apache.hadoop.ozone.RatisTestHelper;
import org.apache.hadoop.ozone.container.ContainerTestHelper;
@@ -179,7 +180,8 @@ public class TestSecureContainerServer {
XceiverClientSpi finalClient = client;
LambdaTestUtils.intercept(IOException.class,
- () -> finalClient.sendCommand(request));
+ () -> ContainerProtocolCalls
+ .validateContainerResponse(finalClient.sendCommand(request)));
// Test 2: Test success in request with valid block token.
final ContainerCommandRequestProto request2 =
@@ -191,7 +193,8 @@ public class TestSecureContainerServer {
XceiverClientSpi finalClient2 = client;
LambdaTestUtils.intercept(IOException.class, "",
- () -> finalClient2.sendCommand(request));
+ () -> ContainerProtocolCalls
+ .validateContainerResponse(finalClient2.sendCommand(request)));
} finally {
if (client != null) {
client.close();
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org