This is an automated email from the ASF dual-hosted git repository. chriss pushed a commit to branch support/nifi-1.x in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/support/nifi-1.x by this push: new 2faac7d26e NIFI-11778 fix PutElasticsearchJsonTest for Java 8 2faac7d26e is described below commit 2faac7d26eeceeee2e24f50cd7b8ad35f0f09f6c Author: Chris Sampson <chris.sampso...@gmail.com> AuthorDate: Tue Aug 29 09:58:25 2023 +0100 NIFI-11778 fix PutElasticsearchJsonTest for Java 8 --- .../apache/nifi/processors/elasticsearch/JsonUtils.java | 12 +++++++----- .../elasticsearch/PutElasticsearchJsonTest.java | 15 +++++++-------- 2 files changed, 14 insertions(+), 13 deletions(-) diff --git a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/java/org/apache/nifi/processors/elasticsearch/JsonUtils.java b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/java/org/apache/nifi/processors/elasticsearch/JsonUtils.java index a1d097a976..745c792caf 100644 --- a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/java/org/apache/nifi/processors/elasticsearch/JsonUtils.java +++ b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/java/org/apache/nifi/processors/elasticsearch/JsonUtils.java @@ -31,6 +31,13 @@ public class JsonUtils { private static final ObjectMapper MAPPER = new ObjectMapper(); private JsonUtils() {} + @Deprecated // Use Files.readString when no longer need to support Java 8 + static String readString(final Path path) throws IOException { + try (Stream<String> lines = Files.lines(path)) { + return lines.collect(Collectors.joining("\n")); + } + } + static String toJson(Object object) { try { return MAPPER.writeValueAsString(object); @@ -56,11 +63,6 @@ public class JsonUtils { } } - static String readString(final Path path) throws IOException { - try (Stream<String> lines = Files.lines(path)) { - return lines.collect(Collectors.joining("\n")); - } - } static List<String> readListOfMapsAsIndividualJson(String json) { return readListOfMaps(json).stream() .map(JsonUtils::prettyPrint) diff --git a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/java/org/apache/nifi/processors/elasticsearch/PutElasticsearchJsonTest.java b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/java/org/apache/nifi/processors/elasticsearch/PutElasticsearchJsonTest.java index 3ccee86693..4f8c3df5d5 100644 --- a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/java/org/apache/nifi/processors/elasticsearch/PutElasticsearchJsonTest.java +++ b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/test/java/org/apache/nifi/processors/elasticsearch/PutElasticsearchJsonTest.java @@ -28,7 +28,6 @@ import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; -import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; import java.util.Collections; @@ -62,10 +61,10 @@ public class PutElasticsearchJsonTest extends AbstractPutElasticsearchTest<PutEl @BeforeAll public static void setUpBeforeClass() throws Exception { - sampleErrorResponse = Files.readString(Paths.get(TEST_COMMON_DIR,"sampleErrorResponse.json")); - flowFileContents = Files.readString(Paths.get(TEST_DIR, "flowFileContents.json")); - script = Files.readString(Paths.get(TEST_DIR,"script.json")); - dynamicTemplates = Files.readString(Paths.get(TEST_COMMON_DIR,"dynamicTemplates.json")); + sampleErrorResponse = JsonUtils.readString(Paths.get(TEST_COMMON_DIR,"sampleErrorResponse.json")); + flowFileContents = JsonUtils.readString(Paths.get(TEST_DIR, "flowFileContents.json")); + script = JsonUtils.readString(Paths.get(TEST_DIR,"script.json")); + dynamicTemplates = JsonUtils.readString(Paths.get(TEST_COMMON_DIR,"dynamicTemplates.json")); expectedScript = new LinkedHashMap<>(); expectedScript.put("_source", "some script"); expectedScript.put("language", "painless"); @@ -324,7 +323,7 @@ public class PutElasticsearchJsonTest extends AbstractPutElasticsearchTest<PutEl runner.setProperty(PutElasticsearchJson.BATCH_SIZE, "100"); runner.setProperty(PutElasticsearchJson.NOT_FOUND_IS_SUCCESSFUL, "true"); clientService.setResponse(IndexOperationResponse.fromJsonResponse(sampleErrorResponse)); - List<String> values = JsonUtils.readListOfMapsAsIndividualJson(Files.readString(BATCH_WITH_ERROR)); + List<String> values = JsonUtils.readListOfMapsAsIndividualJson(JsonUtils.readString(BATCH_WITH_ERROR)); values.forEach(val -> runner.enqueue(val)); runner.assertValid(); runner.run(); @@ -365,7 +364,7 @@ public class PutElasticsearchJsonTest extends AbstractPutElasticsearchTest<PutEl runner.setProperty(PutElasticsearchJson.NOT_FOUND_IS_SUCCESSFUL, "false"); runner.setProperty(PutElasticsearchJson.OUTPUT_ERROR_RESPONSES, "true"); clientService.setResponse(IndexOperationResponse.fromJsonResponse(sampleErrorResponse)); - List<String> values = JsonUtils.readListOfMapsAsIndividualJson(Files.readString(BATCH_WITH_ERROR)); + List<String> values = JsonUtils.readListOfMapsAsIndividualJson(JsonUtils.readString(BATCH_WITH_ERROR)); values.forEach(val -> runner.enqueue(val)); runner.assertValid(); runner.run(); @@ -416,7 +415,7 @@ public class PutElasticsearchJsonTest extends AbstractPutElasticsearchTest<PutEl runner.setProperty(PutElasticsearchJson.LOG_ERROR_RESPONSES, "false"); runner.setProperty(PutElasticsearchJson.BATCH_SIZE, "100"); clientService.setResponse(IndexOperationResponse.fromJsonResponse(sampleErrorResponse)); - for (final String val : JsonUtils.readListOfMapsAsIndividualJson(Files.readString(Paths.get(TEST_DIR, "batchWithoutError.json")))) { + for (final String val : JsonUtils.readListOfMapsAsIndividualJson(JsonUtils.readString(Paths.get(TEST_DIR, "batchWithoutError.json")))) { runner.enqueue(val); }