From 00eded81be93f983d55a1f759e1ae2d5a123fafe Mon Sep 17 00:00:00 2001 From: wgzhao Date: Wed, 30 Oct 2024 23:33:27 +0800 Subject: [PATCH] [update][plugin][esreader] Simplify condition judge --- .../addax/plugin/reader/elasticsearchreader/ESClient.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) 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,