Github user MikeThomsen commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2562#discussion_r177131556
--- Diff:
nifi-nar-bundles/nifi-influxdb-bundle/nifi-influxdb-processors/src/test/java/org/apache/nifi/processors/influxdb/AbstractITInfluxDB.java
---
@@ -36,14 +36,7 @@
protected void initInfluxDB() throws InterruptedException, Exception {
influxDB = InfluxDBFactory.connect(dbUrl,user,password);
- if ( influxDB.databaseExists(dbName) ) {
- QueryResult result = influxDB.query(new Query("DROP
measurement water", dbName));
- checkError(result);
- result = influxDB.query(new Query("DROP measurement testm",
dbName));
- checkError(result);
- result = influxDB.query(new Query("DROP database " + dbName,
dbName));
- Thread.sleep(1000);
- }
+ cleanUpDatabase();
--- End diff --
What I meant was that the cleanup functionality shouldn't be called in the
init, but should be called from the `@After` annotated method.
---
