From 882cfff9f8249248ff09b5898389523512ede40b Mon Sep 17 00:00:00 2001 From: Jungtaek Lim Date: Fri, 27 Jul 2018 16:58:37 +0900 Subject: [PATCH] STORM-3161 Local mode should force setting min replication count to 1 When topology.min.replication.count is set to more than 1, nimbus in local mode never achieve condition for replication, hence stuck on handling blobs. We should force set it to 1 in local mode to avoid this situation. --- storm-server/src/main/java/org/apache/storm/LocalCluster.java | 1 + 1 file changed, 1 insertion(+) diff --git a/storm-server/src/main/java/org/apache/storm/LocalCluster.java b/storm-server/src/main/java/org/apache/storm/LocalCluster.java index 0e314c9f026..11f765b4073 100644 --- a/storm-server/src/main/java/org/apache/storm/LocalCluster.java +++ b/storm-server/src/main/java/org/apache/storm/LocalCluster.java @@ -208,6 +208,7 @@ private LocalCluster(Builder builder) throws Exception { conf.put(Config.STORM_CLUSTER_MODE, "local"); conf.put(Config.BLOBSTORE_SUPERUSER, System.getProperty("user.name")); conf.put(Config.BLOBSTORE_DIR, nimbusTmp.getPath()); + conf.put(Config.TOPOLOGY_MIN_REPLICATION_COUNT, 1); InProcessZookeeper zookeeper = null; if (!builder.daemonConf.containsKey(Config.STORM_ZOOKEEPER_SERVERS)) {