You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by sz...@apache.org on 2017/12/03 22:25:58 UTC
incubator-ratis git commit: RATIS-163. TestRaftWithHadoopRpc fails
becuse hadoop rpc retry logic. Contributed by Elek, Marton.
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 <sz...@hortonworks.com>
Authored: Mon Dec 4 06:25:18 2017 +0800
Committer: Tsz-Wo Nicholas Sze <sz...@hortonworks.com>
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(