You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2022/01/11 03:52:45 UTC
[iotdb] 03/03: fix it
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch iotdb-2277
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1a9f00f25d0745cc7a404345b9d1d49dffcfd31f
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Tue Jan 11 11:48:59 2022 +0800
fix it
---
.../org/apache/iotdb/db/integration/IoTDBContinuousQueryIT.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBContinuousQueryIT.java b/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBContinuousQueryIT.java
index cbfff06..dbf91d7 100644
--- a/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBContinuousQueryIT.java
+++ b/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBContinuousQueryIT.java
@@ -127,12 +127,12 @@ public class IoTDBContinuousQueryIT {
+ "GROUP BY time(1s) END");
statement.execute(
"CREATE CONTINUOUS QUERY cq2 "
- + "BEGIN SELECT count(temperature) INTO temperature_cnt FROM root.ln.wf01.*.* "
+ + "BEGIN SELECT avg(temperature) INTO temperature_cnt FROM root.ln.wf01.*.* "
+ " GROUP BY time(1s), level=3 END");
statement.execute(
"CREATE CONTINUOUS QUERY cq3 "
+ "RESAMPLE EVERY 2s FOR 2s "
- + "BEGIN SELECT avg(temperature) INTO temperature_avg FROM root.ln.wf01.*.* "
+ + "BEGIN SELECT min_value(temperature) INTO temperature_avg FROM root.ln.wf01.*.* "
+ "GROUP BY time(1s), level=2 END");
statement.execute("DROP CONTINUOUS QUERY cq1");
@@ -166,11 +166,11 @@ public class IoTDBContinuousQueryIT {
statement.execute(
"CREATE CONTINUOUS QUERY cq1 "
- + "BEGIN SELECT max_value(temperature) INTO temperature_max FROM root.ln.*.*.* "
+ + "BEGIN SELECT sum(temperature) INTO temperature_max FROM root.ln.*.*.* "
+ "GROUP BY time(1s) END");
statement.execute(
"CREATE CONTINUOUS QUERY cq2 "
- + "BEGIN SELECT count(temperature) INTO temperature_cnt FROM root.ln.wf01.*.* "
+ + "BEGIN SELECT avg(temperature) INTO temperature_cnt FROM root.ln.wf01.*.* "
+ " GROUP BY time(1s), level=3 END");
checkShowContinuousQueriesResult(new String[] {"cq3", "cq1", "cq2"});