From dfce52589a2666a656c8c8f83ceb16000b4aeeaf Mon Sep 17 00:00:00 2001 From: 07Himank <112613760+07Himank@users.noreply.github.com> Date: Fri, 13 Oct 2023 04:39:03 +0530 Subject: [PATCH] Fix credentials issue elastic search (#13552) * Fix Crentials issue on Elastic Search * checkstyle --- .../service/search/elasticsearch/ElasticSearchClient.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java b/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java index f32c02b8184..3dd227a8a4a 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/search/elasticsearch/ElasticSearchClient.java @@ -1475,9 +1475,6 @@ public class ElasticSearchClient implements SearchClient { RestClientBuilder restClientBuilder = RestClient.builder(new HttpHost(esConfig.getHost(), esConfig.getPort(), esConfig.getScheme())); - RestClient restClient = - RestClient.builder(new HttpHost(esConfig.getHost(), esConfig.getPort(), esConfig.getScheme())).build(); - if (StringUtils.isNotEmpty(esConfig.getUsername()) && StringUtils.isNotEmpty(esConfig.getPassword())) { CredentialsProvider credentialsProvider = new BasicCredentialsProvider(); credentialsProvider.setCredentials( @@ -1502,7 +1499,7 @@ public class ElasticSearchClient implements SearchClient { requestConfigBuilder .setConnectTimeout(esConfig.getConnectionTimeoutSecs() * 1000) .setSocketTimeout(esConfig.getSocketTimeoutSecs() * 1000)); - return new RestHighLevelClientBuilder(restClient).setApiCompatibilityMode(true).build(); + return new RestHighLevelClientBuilder(restClientBuilder.build()).setApiCompatibilityMode(true).build(); } catch (Exception e) { LOG.error("Failed to create elastic search client ", e); return null;