Repository: incubator-ratis Updated Branches: refs/heads/master 874e48b78 -> 1a74e13ea
RATIS-163. TestRaftWithHadoopRpc fails becuse hadoop rpc retry logic. Contributed by Elek, Marton. Project: http://git-wip-us.apache.org/repos/asf/incubator-ratis/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ratis/commit/1a74e13e Tree: http://git-wip-us.apache.org/repos/asf/incubator-ratis/tree/1a74e13e Diff: http://git-wip-us.apache.org/repos/asf/incubator-ratis/diff/1a74e13e Branch: refs/heads/master Commit: 1a74e13ea8eb614cdd62f3d87d4926717ca4be92 Parents: 874e48b Author: Tsz-Wo Nicholas Sze <[email protected]> Authored: Mon Dec 4 06:25:18 2017 +0800 Committer: Tsz-Wo Nicholas Sze <[email protected]> Committed: Mon Dec 4 06:25:18 2017 +0800 ---------------------------------------------------------------------- .../hadooprpc/TestRaftExceptionWithHadoopRpc.java | 17 +++++++++++++++++ .../ratis/hadooprpc/TestRaftWithHadoopRpc.java | 1 + 2 files changed, 18 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ratis/blob/1a74e13e/ratis-hadoop/src/test/java/org/apache/ratis/hadooprpc/TestRaftExceptionWithHadoopRpc.java ---------------------------------------------------------------------- diff --git a/ratis-hadoop/src/test/java/org/apache/ratis/hadooprpc/TestRaftExceptionWithHadoopRpc.java b/ratis-hadoop/src/test/java/org/apache/ratis/hadooprpc/TestRaftExceptionWithHadoopRpc.java index c60e183..33e4b42 100644 --- a/ratis-hadoop/src/test/java/org/apache/ratis/hadooprpc/TestRaftExceptionWithHadoopRpc.java +++ b/ratis-hadoop/src/test/java/org/apache/ratis/hadooprpc/TestRaftExceptionWithHadoopRpc.java @@ -17,9 +17,26 @@ */ package org.apache.ratis.hadooprpc; +import org.apache.hadoop.conf.Configuration; +import org.apache.hadoop.fs.CommonConfigurationKeys; import org.apache.ratis.RaftExceptionBaseTest; +import org.apache.ratis.conf.RaftProperties; + +import java.io.IOException; public class TestRaftExceptionWithHadoopRpc extends RaftExceptionBaseTest<MiniRaftClusterWithHadoopRpc> implements MiniRaftClusterWithHadoopRpc.Factory.Get { + + @Override + public MiniRaftClusterWithHadoopRpc newCluster(int numPeers) throws IOException { + final Configuration conf = new Configuration(); + HadoopConfigKeys.Ipc.setHandlers(conf, 20); + conf.setInt(CommonConfigurationKeys.IPC_CLIENT_CONNECT_MAX_RETRIES_KEY, 0); + conf.setInt(CommonConfigurationKeys.IPC_SERVER_HANDLER_QUEUE_SIZE_KEY, 1000); + conf.setInt(CommonConfigurationKeys.IPC_CLIENT_RPC_TIMEOUT_KEY, 1000); + return MiniRaftClusterWithHadoopRpc.FACTORY.newCluster(numPeers, getProperties(), conf); + } + + } http://git-wip-us.apache.org/repos/asf/incubator-ratis/blob/1a74e13e/ratis-hadoop/src/test/java/org/apache/ratis/hadooprpc/TestRaftWithHadoopRpc.java ---------------------------------------------------------------------- diff --git a/ratis-hadoop/src/test/java/org/apache/ratis/hadooprpc/TestRaftWithHadoopRpc.java b/ratis-hadoop/src/test/java/org/apache/ratis/hadooprpc/TestRaftWithHadoopRpc.java index 1c21242..b977c18 100644 --- a/ratis-hadoop/src/test/java/org/apache/ratis/hadooprpc/TestRaftWithHadoopRpc.java +++ b/ratis-hadoop/src/test/java/org/apache/ratis/hadooprpc/TestRaftWithHadoopRpc.java @@ -39,6 +39,7 @@ public class TestRaftWithHadoopRpc extends RaftBasicTests { public TestRaftWithHadoopRpc() throws IOException { final Configuration conf = new Configuration(); HadoopConfigKeys.Ipc.setHandlers(conf, 20); + conf.setInt(CommonConfigurationKeys.IPC_CLIENT_CONNECT_MAX_RETRIES_KEY, 0); conf.setInt(CommonConfigurationKeys.IPC_SERVER_HANDLER_QUEUE_SIZE_KEY, 1000); conf.setInt(CommonConfigurationKeys.IPC_CLIENT_RPC_TIMEOUT_KEY, 1000); cluster = MiniRaftClusterWithHadoopRpc.FACTORY.newCluster(
