Skip to content

Commit b49aaac

Browse files
authored
Fix C++ query dataset timeout propagation (#17399)
1 parent 7054c8a commit b49aaac

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -213,6 +213,7 @@ bool IoTDBRpcDataSet::fetchResults() {
213213
TSFetchResultsResp resp;
214214
client_->fetchResultsV2(resp, req);
215215
RpcUtils::verifySuccess(resp.status);
216+
moreData_ = resp.moreData;
216217
if (!resp.hasResultSet) {
217218
close();
218219
}

iotdb-client/client-cpp/src/main/SessionConnection.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -209,7 +209,7 @@ std::unique_ptr<SessionDataSet> SessionConnection::executeQueryStatement(const s
209209
return std::unique_ptr<SessionDataSet>(new SessionDataSet(sql, resp.columns, resp.dataTypeList,
210210
resp.columnNameIndexMap, resp.queryId, statementId,
211211
client, sessionId, resp.queryResult, resp.ignoreTimeStamp,
212-
connectionTimeoutInMs, resp.moreData, fetchSize, zoneId,
212+
timeoutInMs, resp.moreData, fetchSize, zoneId,
213213
timeFactor, resp.columnIndex2TsBlockColumnIndexList));
214214
}
215215

0 commit comments

Comments
 (0)