aboutsummaryrefslogtreecommitdiff
path: root/contrib/storage-mongo
diff options
context:
space:
mode:
authorTimothy Farkas <timothyfarkas@apache.org>2018-05-02 01:21:10 -0700
committerVolodymyr Vysotskyi <vvovyk@gmail.com>2018-05-05 20:12:47 +0300
commit6cbba282d17d1670da5dd8788d1318a77abc0bf7 (patch)
tree3d460d3d5b5ce9e5ec0ae8577c350893441a7813 /contrib/storage-mongo
parentd0a7545c854e5ef99ed45edd1fe3520aa6dcaa74 (diff)
DRILL-6380: Fix sporadic mongo db hangs.
closes #1249
Diffstat (limited to 'contrib/storage-mongo')
-rw-r--r--contrib/storage-mongo/src/test/java/org/apache/drill/exec/store/mongo/MongoTestSuit.java12
1 files changed, 8 insertions, 4 deletions
diff --git a/contrib/storage-mongo/src/test/java/org/apache/drill/exec/store/mongo/MongoTestSuit.java b/contrib/storage-mongo/src/test/java/org/apache/drill/exec/store/mongo/MongoTestSuit.java
index b3f0bd137..487396d70 100644
--- a/contrib/storage-mongo/src/test/java/org/apache/drill/exec/store/mongo/MongoTestSuit.java
+++ b/contrib/storage-mongo/src/test/java/org/apache/drill/exec/store/mongo/MongoTestSuit.java
@@ -20,9 +20,10 @@ package org.apache.drill.exec.store.mongo;
import java.io.IOException;
import java.net.UnknownHostException;
import java.util.ArrayList;
-import java.util.HashMap;
+import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
+import java.util.TreeMap;
import java.util.concurrent.atomic.AtomicInteger;
import com.google.common.collect.Lists;
@@ -94,7 +95,9 @@ public class MongoTestSuit implements MongoTestConstants {
configServers.add(crateConfigServerConfig(CONFIG_SERVER_3_PORT));
// creating replicaSets
- Map<String, List<IMongodConfig>> replicaSets = new HashMap<>();
+ // A LinkedHashMap ensures that the config servers are started first.
+ Map<String, List<IMongodConfig>> replicaSets = new LinkedHashMap<>();
+
List<IMongodConfig> replicaSet1 = new ArrayList<>();
replicaSet1.add(crateIMongodConfig(MONGOD_1_PORT, false,
REPLICA_SET_1_NAME));
@@ -102,7 +105,6 @@ public class MongoTestSuit implements MongoTestConstants {
REPLICA_SET_1_NAME));
replicaSet1.add(crateIMongodConfig(MONGOD_3_PORT, false,
REPLICA_SET_1_NAME));
- replicaSets.put(REPLICA_SET_1_NAME, replicaSet1);
List<IMongodConfig> replicaSet2 = new ArrayList<>();
replicaSet2.add(crateIMongodConfig(MONGOD_4_PORT, false,
REPLICA_SET_2_NAME));
@@ -110,8 +112,10 @@ public class MongoTestSuit implements MongoTestConstants {
REPLICA_SET_2_NAME));
replicaSet2.add(crateIMongodConfig(MONGOD_6_PORT, false,
REPLICA_SET_2_NAME));
- replicaSets.put(REPLICA_SET_2_NAME, replicaSet2);
+
replicaSets.put(CONFIG_REPLICA_SET, configServers);
+ replicaSets.put(REPLICA_SET_1_NAME, replicaSet1);
+ replicaSets.put(REPLICA_SET_2_NAME, replicaSet2);
// create mongos
IMongosConfig mongosConfig = createIMongosConfig();