diff --git a/plugin/reader/elasticsearchreader/src/main/java/com/wgzhao/addax/plugin/reader/elasticsearchreader/ESClient.java b/plugin/reader/elasticsearchreader/src/main/java/com/wgzhao/addax/plugin/reader/elasticsearchreader/ESClient.java index bb187e6df..141495c30 100644 --- a/plugin/reader/elasticsearchreader/src/main/java/com/wgzhao/addax/plugin/reader/elasticsearchreader/ESClient.java +++ b/plugin/reader/elasticsearchreader/src/main/java/com/wgzhao/addax/plugin/reader/elasticsearchreader/ESClient.java @@ -100,21 +100,19 @@ public boolean indicesExists(String indexName) boolean isIndicesExists = false; JestResult rst = jestClient.execute(new IndicesExists.Builder(indexName).build()); if (rst.isSucceeded()) { - isIndicesExists = true; + return true; } else { switch (rst.getResponseCode()) { case 404: - isIndicesExists = false; - break; + return false; case 401: // 无权访问 default: log.warn(rst.getErrorMessage()); - break; + return false; } } - return isIndicesExists; } public SearchResult search(String query,