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