From 420423b775116e96d7761971e573670e9843d627 Mon Sep 17 00:00:00 2001 From: Viet Nguyen Date: Tue, 22 Oct 2024 18:15:22 +1100 Subject: [PATCH] update bug --- .../aodn/esindexer/service/ElasticSearchIndexService.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/indexer/src/main/java/au/org/aodn/esindexer/service/ElasticSearchIndexService.java b/indexer/src/main/java/au/org/aodn/esindexer/service/ElasticSearchIndexService.java index ccdb9809..9bb5577b 100644 --- a/indexer/src/main/java/au/org/aodn/esindexer/service/ElasticSearchIndexService.java +++ b/indexer/src/main/java/au/org/aodn/esindexer/service/ElasticSearchIndexService.java @@ -48,12 +48,11 @@ public void createIndexFromMappingJSONFile(String indexMappingFile, String index log.info("Reading index schema definition from JSON file: {}", indexMappingFile); // https://www.baeldung.com/java-classpath-resource-cannot-be-opened#resources - try (InputStream inputStream = getClass().getResourceAsStream("config_files/" + indexMappingFile); - BufferedReader reader = new BufferedReader(new InputStreamReader(Objects.requireNonNull(inputStream)))) { + try (InputStream inputStream = getClass().getResourceAsStream("/config_files/" + indexMappingFile);) { log.info("Creating index: {}", indexName); CreateIndexRequest req = CreateIndexRequest.of(b -> b .index(indexName) - .withJson(reader) + .withJson(inputStream) ); CreateIndexResponse response = portalElasticsearchClient.indices().create(req); log.info(response.toString());