Skip to content

Commit 39997ea

Browse files
committed
fix status code
1 parent 4fefd5c commit 39997ea

File tree

3 files changed

+4
-7
lines changed

3 files changed

+4
-7
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -617,7 +617,7 @@ private ExecutionResult getExecutionResult(QueryState state) {
617617
// info to client
618618
if (!CONFIG.isEnable13DataInsertAdapt()
619619
|| IoTDBConstant.ClientVersion.V_1_0.equals(context.getSession().getVersion())) {
620-
planner.setRedirectInfo(analysis, CONFIG.getAddressAndPort(), tsstatus, statusCode);
620+
planner.setRedirectInfo(analysis, CONFIG.getAddressAndPort(), tsstatus);
621621
}
622622

623623
return new ExecutionResult(context.getQueryId(), tsstatus);

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/IPlanner.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@
2727
import org.apache.iotdb.db.queryengine.plan.planner.plan.DistributedQueryPlan;
2828
import org.apache.iotdb.db.queryengine.plan.planner.plan.LogicalQueryPlan;
2929
import org.apache.iotdb.db.queryengine.plan.scheduler.IScheduler;
30-
import org.apache.iotdb.rpc.TSStatusCode;
3130

3231
import java.util.concurrent.ScheduledExecutorService;
3332

@@ -49,6 +48,5 @@ IScheduler doSchedule(
4948

5049
ScheduledExecutorService getScheduledExecutorService();
5150

52-
void setRedirectInfo(
53-
IAnalysis analysis, TEndPoint localEndPoint, TSStatus tsstatus, TSStatusCode statusCode);
51+
void setRedirectInfo(IAnalysis analysis, TEndPoint localEndPoint, TSStatus tsstatus);
5452
}

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TreeModelPlanner.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -156,8 +156,7 @@ public ScheduledExecutorService getScheduledExecutorService() {
156156
}
157157

158158
@Override
159-
public void setRedirectInfo(
160-
IAnalysis iAnalysis, TEndPoint localEndPoint, TSStatus tsstatus, TSStatusCode statusCode) {
159+
public void setRedirectInfo(IAnalysis iAnalysis, TEndPoint localEndPoint, TSStatus tsstatus) {
161160
Analysis analysis = (Analysis) iAnalysis;
162161

163162
// Get the inner statement of PipeEnrichedStatement
@@ -173,7 +172,7 @@ public void setRedirectInfo(
173172
if (insertStatement instanceof InsertRowsStatement
174173
|| insertStatement instanceof InsertMultiTabletsStatement) {
175174
// multiple devices
176-
if (statusCode == TSStatusCode.SUCCESS_STATUS) {
175+
if (tsstatus.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
177176
boolean needRedirect = false;
178177
List<TSStatus> subStatus = new ArrayList<>();
179178
for (TEndPoint endPoint : redirectNodeList) {

0 commit comments

Comments
 (0)