fix CI and add peek in clearTask

Signed-off-by: Weihao Li <[email protected]>

Author: Wei-hao-Li

integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDatabaseIT.java

@@ -399,6 +399,7 @@ public void testInformationSchema() throws SQLException {
               "config_nodes,INF,",
               "configurations,INF,",
               "connections,INF,",
+              "current_queries,INF,",
               "data_nodes,INF,",
               "databases,INF,",
               "functions,INF,",
@@ -408,6 +409,7 @@ public void testInformationSchema() throws SQLException {
               "pipe_plugins,INF,",
               "pipes,INF,",
               "queries,INF,",
+              "queries_costs_histogram,INF,",
               "regions,INF,",
               "subscriptions,INF,",
               "tables,INF,",

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/Coordinator.java

@@ -831,10 +831,17 @@ private void clearExpiredQueriesInfoTask() {
 
     // the QueryInfo smaller than expired time will be cleared
     long expiredTime = System.currentTimeMillis() - queryCostStatWindow * 60 * 1_000;
-    QueryInfo queryInfo = currentQueriesInfo.poll();
+    // peek head, the head QueryInfo is in the time window, return directly
+    QueryInfo queryInfo = currentQueriesInfo.peekFirst();
+    if (queryInfo.endTime >= expiredTime) {
+      return;
+    }
+
+    queryInfo = currentQueriesInfo.poll();
     while (queryInfo != null) {
       if (queryInfo.endTime < expiredTime) {
         // out of time window, clear queryInfo
+        coordinatorMemoryBlock.release(RamUsageEstimator.sizeOfObject(queryInfo));
         unrecordInHistogram(queryInfo.costTime);
         queryInfo = currentQueriesInfo.poll();
       } else {