This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch IOTDB-4619
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/IOTDB-4619 by this push:
new 4e561ef090 Add logs
4e561ef090 is described below
commit 4e561ef090a5881337b7393136e317638021ad8c
Author: JackieTien97 <[email protected]>
AuthorDate: Tue Oct 18 10:28:11 2022 +0800
Add logs
---
.../java/org/apache/iotdb/confignode/manager/cq/CQScheduleTask.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQScheduleTask.java
b/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQScheduleTask.java
index 48ab4e3b8e..c048802c78 100644
---
a/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQScheduleTask.java
+++
b/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQScheduleTask.java
@@ -153,8 +153,9 @@ public class CQScheduleTask implements Runnable {
}
} else {
LOGGER.info(
- "[StartExecuteCQ] {}, time range is [{}, {}), current time is {}",
+ "[StartExecuteCQ] execute CQ {} on DataNode[{}], time range is [{},
{}), current time is {}",
cqId,
+ targetDataNode.get().dataNodeId,
startTime,
endTime,
System.currentTimeMillis());