This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a commit to branch AuthEnhance
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/AuthEnhance by this push:
new 98bd5a7779e modify thrift
98bd5a7779e is described below
commit 98bd5a7779ef959095dbc8c99b0a06cc5b779b1f
Author: shuwenwei <[email protected]>
AuthorDate: Wed Sep 17 11:28:51 2025 +0800
modify thrift
---
iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift | 2 +-
iotdb-protocol/thrift-datanode/src/main/thrift/datanode.thrift | 7 ++++++-
2 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift
b/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift
index 4fd8845137a..2f1b4302c3e 100644
--- a/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift
+++ b/iotdb-protocol/thrift-confignode/src/main/thrift/confignode.thrift
@@ -1758,7 +1758,7 @@ service IConfigNodeRPCService {
common.TSStatus removeRegion(TRemoveRegionReq req)
/** Kill query */
- common.TSStatus killQuery(string queryId, i32 dataNodeId)
+ common.TSStatus killQuery(string queryId, i32 dataNodeId, string
allowedUsername)
/** Get all DataNodeLocations of Readable DataNodes */
TGetDataNodeLocationsResp getReadableDataNodeLocations()
diff --git a/iotdb-protocol/thrift-datanode/src/main/thrift/datanode.thrift
b/iotdb-protocol/thrift-datanode/src/main/thrift/datanode.thrift
index 6b44d1a6ef2..e76eb605f96 100644
--- a/iotdb-protocol/thrift-datanode/src/main/thrift/datanode.thrift
+++ b/iotdb-protocol/thrift-datanode/src/main/thrift/datanode.thrift
@@ -740,6 +740,11 @@ struct TFetchFragmentInstanceStatisticsResp {
17: optional i32 initDataQuerySourceRetryCount
}
+struct TKillQueryInstanceReq {
+ 1: optional string queryId
+ 2: optional string allowedUsername
+}
+
/**
* END: Used for EXPLAIN ANALYZE
**/
@@ -997,7 +1002,7 @@ service IDataNodeRPCService {
common.TSStatus setSystemStatus(string status)
- common.TSStatus killQueryInstance(string queryId)
+ common.TSStatus killQueryInstance(TKillQueryInstanceReq req)
/**
* Config node will Set the TTL for the database on a list of data nodes.
