Github user mans2singh commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2562#discussion_r179012098
--- Diff:
nifi-nar-bundles/nifi-influxdb-bundle/nifi-influxdb-processors/src/test/java/org/apache/nifi/processors/influxdb/ITExecuteInfluxDBQuery.java
---
@@ -110,8 +125,72 @@ public void testCreateDB() {
assertEquals("Value should be equal",null,
flowFiles.get(0).getAttribute(ExecuteInfluxDBQuery.INFLUX_DB_ERROR_MESSAGE));
assertEquals("Value should be equal",query,
flowFiles.get(0).getAttribute(ExecuteInfluxDBQuery.INFLUX_DB_EXECUTED_QUERY));
- flowFiles.get(0).assertContentEquals("{\"results\":[{}]}");
+ QueryResult queryResult = gson.fromJson(new StringReader(new
String(flowFiles.get(0).toByteArray())), QueryResult.class);
+ assertEquals("results array should be empty", 1,
queryResult.getResults().size());
+ assertEquals("No series", null,
queryResult.getResults().get(0).getSeries());
--- End diff --
Corrected.
---
