database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix] fix http_stream retry mechanism (#23969)

Browse Source 
Co-authored-by: yiguolei <676222867@qq.com>
This commit is contained in:
zzzzzzzs
2023-09-14 21:41:11 +08:00
committed by GitHub
parent 07720d3ff9
commit 05e365ea13
9 changed files with 9 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
View File

@ -41,7 +41,6 @@ import org.apache.doris.resource.Tag;
import org.apache.doris.statistics.ColumnStatistic;
import org.apache.doris.statistics.Histogram;
import org.apache.doris.system.Backend;
import org.apache.doris.task.LoadTaskInfo;
import org.apache.doris.thrift.TUniqueId;
import org.apache.doris.transaction.TransactionEntry;
import org.apache.doris.transaction.TransactionStatus;
@ -78,9 +77,7 @@ public class ConnectContext {
protected volatile long forwardedStmtId;
// set for http_stream
protected volatile TUniqueId loadId;
protected volatile long backendId;
protected volatile LoadTaskInfo streamLoadInfo;
protected volatile TUniqueId queryId;
protected volatile String traceId;
@ -338,22 +335,6 @@ public class ConnectContext {
this.backendId = backendId;
}
public TUniqueId getLoadId() {
return loadId;
}
public void setLoadId(TUniqueId loadId) {
this.loadId = loadId;
}
public void setStreamLoadInfo(LoadTaskInfo streamLoadInfo) {
this.streamLoadInfo = streamLoadInfo;
}
public LoadTaskInfo getStreamLoadInfo() {
return streamLoadInfo;
}
public void setStmtId(long stmtId) {
this.stmtId = stmtId;
}