Fix it #108

vipshop · Mar 20, 2017 · 5e51e27 · 5e51e27
1 parent ea47ea8
commit 5e51e27
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-sharding/src/main/java/com/vip/saturn/job/sharding/service/NamespaceShardingService.java b/...-sharding/src/main/java/com/vip/saturn/job/sharding/service/NamespaceShardingService.java
@@ -228,7 +228,7 @@ private void increaseShardingCount() throws Exception {
 				}
 				curatorFramework.setData().forPath(SaturnExecutorsNode.SHARDING_COUNT_PATH, _shardingCount.toString().getBytes("UTF-8"));
 			} else {
-				curatorFramework.create().forPath(SaturnExecutorsNode.SHARDING_COUNT_PATH, _shardingCount.toString().getBytes("UTF-8"));
+				curatorFramework.create().creatingParentsIfNeeded().forPath(SaturnExecutorsNode.SHARDING_COUNT_PATH, _shardingCount.toString().getBytes("UTF-8"));
 			}
 		}