Github user ottobackwards commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2760#discussion_r193183815
--- Diff:
nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/test/java/org/apache/nifi/processors/elasticsearch/PutElasticsearchHttpRecordIT.java
---
@@ -227,6 +227,29 @@ public void testBadIndexName() throws Exception {
runner.assertTransferCount(PutElasticsearchHttpRecord.REL_SUCCESS,
0);
}
+ @Test
+ public void testIndexNameWithJsonChar() throws Exception {
+ // Undo some stuff from setup()
+ runner.setProperty(PutElasticsearchHttpRecord.INDEX,
"people}test");
+ runner.setProperty(PutElasticsearchHttpRecord.TYPE, "person");
+ recordReader.addRecord(1, new MapRecord(personSchema, new
HashMap<String,Object>() {{
+ put("name", "John Doe");
+ put("age", 48);
+ put("sport", null);
+ }}));
+
+ List<Map<String, String>> attrs = new ArrayList<>();
+ Map<String, String> attr = new HashMap<>();
+ attr.put("doc_id", "1");
+ attrs.add(attr);
+
+ runner.enqueue("");
+ runner.run(1, true, true);
+ runner.assertTransferCount(PutElasticsearchHttpRecord.REL_FAILURE,
0);
+ runner.assertTransferCount(PutElasticsearchHttpRecord.REL_RETRY,
0);
--- End diff --
Should this succeed or fail?
---
