diff --git a/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java b/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java index d49f0fe4..bd397e75 100644 --- a/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java +++ b/jetlinks-components/elasticsearch-component/src/main/java/org/jetlinks/community/elastic/search/index/ElasticSearchIndexProperties.java @@ -19,7 +19,7 @@ public class ElasticSearchIndexProperties { public Settings toSettings() { return Settings.builder() - .put("number_of_shards", Math.min(1, numberOfShards)) + .put("number_of_shards", Math.max(1, numberOfShards)) .put("number_of_replicas", numberOfReplicas) .build(); }