This is an automated email from the ASF dual-hosted git repository.
exceptionfactory 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 6634125476 NIFI-4651 Corrected anonymous HashMap usage failing on Java
8
6634125476 is described below
commit 663412547633d971845125130d3ae86b18586005
Author: exceptionfactory <[email protected]>
AuthorDate: Tue Mar 21 18:55:32 2023 -0500
NIFI-4651 Corrected anonymous HashMap usage failing on Java 8
---
.../test/java/org/apache/nifi/processors/standard/TestPutSQL.java | 8 ++------
1 file changed, 2 insertions(+), 6 deletions(-)
diff --git
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestPutSQL.java
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestPutSQL.java
index 3030d7f6ed..ba09b85d63 100644
---
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestPutSQL.java
+++
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestPutSQL.java
@@ -1482,9 +1482,7 @@ public class TestPutSQL {
recreateTable("PERSONS", createPersons);
- runner.enqueue("This statement should be ignored".getBytes(), new
HashMap<>() {{
- put("row.id", "1");
- }});
+ runner.enqueue("This statement should be ignored".getBytes(),
Collections.singletonMap("row.id", "1"));
runner.run();
runner.assertAllFlowFilesTransferred(PutSQL.REL_SUCCESS, 1);
@@ -1501,9 +1499,7 @@ public class TestPutSQL {
}
runner.setProperty(PutSQL.SQL_STATEMENT, "UPDATE PERSONS SET
NAME='George' WHERE ID=${row.id}");
- runner.enqueue("This statement should be ignored".getBytes(), new
HashMap<>() {{
- put("row.id", "1");
- }});
+ runner.enqueue("This statement should be ignored".getBytes(),
Collections.singletonMap("row.id", "1"));
runner.run();
try (final Connection conn = service.getConnection()) {