xbkaishui commented on a change in pull request #5637:
URL: https://github.com/apache/skywalking/pull/5637#discussion_r502744069
##########
File path:
oap-server/server-storage-plugin/storage-influxdb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/influxdb/InfluxClient.java
##########
@@ -161,11 +172,7 @@ public int getCounter(Query query) throws IOException {
*/
public void dropSeries(String measurement, long timeBucket) throws
IOException {
Query query = new Query("DROP SERIES FROM " + measurement + " WHERE
time_bucket='" + timeBucket + "'");
- QueryResult result = getInflux().query(query);
-
- if (result.hasError()) {
- throw new IOException("Statement: " + query.getCommand() + ",
ErrorMsg: " + result.getError());
- }
+ this.query(query);
Review comment:
Same comment as above
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
