[
https://issues.apache.org/jira/browse/NIFI-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16414957#comment-16414957
]
ASF GitHub Bot commented on NIFI-4927:
--------------------------------------
Github user mans2singh commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2562#discussion_r177296457
--- 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 --
I call the cleanup in setup as a precaution so that if there is any
conflicting/previously existing data in the test database, it is removed and
does not fail the integration test which depend on number of rows inserted. If
you think it is unnecessary, I can remove it.
> Create InfluxDB Query Processor
> -------------------------------
>
> Key: NIFI-4927
> URL: https://issues.apache.org/jira/browse/NIFI-4927
> Project: Apache NiFi
> Issue Type: New Feature
> Components: Extensions
> Affects Versions: 1.5.0
> Reporter: Mans Singh
> Assignee: Mans Singh
> Priority: Minor
> Labels: measurements,, query, realtime, timeseries
>
> Create InfluxDB Query processor
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
