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

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


The following commit(s) were added to refs/heads/master by this push:
     new b49aaacc945 Fix C++ query dataset timeout propagation (#17399)
b49aaacc945 is described below

commit b49aaacc94555bd139dd355c92abad18aaa004b7
Author: Hongzhi Gao <[email protected]>
AuthorDate: Tue Mar 31 08:34:02 2026 +0800

    Fix C++ query dataset timeout propagation (#17399)
---
 iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.cpp   | 1 +
 iotdb-client/client-cpp/src/main/SessionConnection.cpp | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.cpp 
b/iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.cpp
index 38bef0ab792..eba013598e4 100644
--- a/iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.cpp
+++ b/iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.cpp
@@ -213,6 +213,7 @@ bool IoTDBRpcDataSet::fetchResults() {
     TSFetchResultsResp resp;
     client_->fetchResultsV2(resp, req);
     RpcUtils::verifySuccess(resp.status);
+    moreData_ = resp.moreData;
     if (!resp.hasResultSet) {
         close();
     }
diff --git a/iotdb-client/client-cpp/src/main/SessionConnection.cpp 
b/iotdb-client/client-cpp/src/main/SessionConnection.cpp
index 7ed903d24fb..e4d369374c8 100644
--- a/iotdb-client/client-cpp/src/main/SessionConnection.cpp
+++ b/iotdb-client/client-cpp/src/main/SessionConnection.cpp
@@ -209,7 +209,7 @@ std::unique_ptr<SessionDataSet> 
SessionConnection::executeQueryStatement(const s
     return std::unique_ptr<SessionDataSet>(new SessionDataSet(sql, 
resp.columns, resp.dataTypeList,
                                                               
resp.columnNameIndexMap, resp.queryId, statementId,
                                                               client, 
sessionId, resp.queryResult, resp.ignoreTimeStamp,
-                                                              
connectionTimeoutInMs, resp.moreData, fetchSize, zoneId,
+                                                              timeoutInMs, 
resp.moreData, fetchSize, zoneId,
                                                               timeFactor, 
resp.columnIndex2TsBlockColumnIndexList));
 }
 

Reply via email to