This is an automated email from the ASF dual-hosted git repository.

caogaofei pushed a commit to branch OptGroupByQuery
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/OptGroupByQuery by this push:
     new 6c993f588ed fix empty full id
6c993f588ed is described below

commit 6c993f588ed962e58a5c217dc4203d0e7add2a73
Author: Beyyes <[email protected]>
AuthorDate: Mon Mar 24 16:13:18 2025 +0800

    fix empty full id
---
 .../iotdb/db/queryengine/execution/schedule/task/DriverTaskId.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/task/DriverTaskId.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/task/DriverTaskId.java
index 865af681b37..3dff2044a6e 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/task/DriverTaskId.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/task/DriverTaskId.java
@@ -36,11 +36,12 @@ public class DriverTaskId implements ID, 
Comparable<DriverTaskId> {
   // Currently, we just save pipelineId in driverTask since it's one-to-one 
relation.
   private final int pipelineId;
   private final String fullId;
+  private static final String EMPTY_FULL_ID = "EmptyFullId";
 
   public DriverTaskId(FragmentInstanceId id, int pipelineId) {
     this.fragmentInstanceId = id;
     this.pipelineId = pipelineId;
-    this.fullId = String.format("%s.%d", id.getFullId(), pipelineId);
+    this.fullId = String.format("%s.%d", id == null ? EMPTY_FULL_ID : 
id.getFullId(), pipelineId);
   }
 
   @Override

Reply via email to