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

[Feature](runtime-filter) add runtime filter breaking change adapt (#13246)

Browse Source 
add runtime filter breaking change adapt
This commit is contained in:
Pxl
2022-10-28 10:59:28 +08:00
committed by GitHub
parent 5805011629
commit 2fab0c45c7
33 changed files with 224 additions and 180 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
View File

@ -250,6 +250,7 @@ public class StreamLoadPlanner {
// for stream load, we use exec_mem_limit to limit the memory usage of load channel.
queryOptions.setLoadMemLimit(taskInfo.getMemLimit());
queryOptions.setEnableVectorizedEngine(Config.enable_vectorized_load);
queryOptions.setBeExecVersion(Config.be_exec_version);
params.setQueryOptions(queryOptions);
TQueryGlobals queryGlobals = new TQueryGlobals();

1
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
View File

@ -313,6 +313,7 @@ public class Coordinator {
private void initQueryOptions(ConnectContext context) {
this.queryOptions = context.getSessionVariable().toThrift();
this.queryOptions.setEnableVectorizedEngine(VectorizedUtil.isVectorized());
this.queryOptions.setBeExecVersion(Config.be_exec_version);
}
public long getJobId() {

2
fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
View File

@ -17,6 +17,7 @@
package org.apache.doris.qe;
import org.apache.doris.common.Config;
import org.apache.doris.common.io.Text;
import org.apache.doris.common.io.Writable;
import org.apache.doris.common.util.TimeUtils;
@ -1170,6 +1171,7 @@ public class SessionVariable implements Serializable, Writable {
tResult.setIsReportSuccess(enableProfile);
tResult.setCodegenLevel(codegenLevel);
tResult.setEnableVectorizedEngine(enableVectorizedEngine);
tResult.setBeExecVersion(Config.be_exec_version);
tResult.setReturnObjectDataAsBinary(returnObjectDataAsBinary);
tResult.setTrimTailingSpacesForExternalTableQuery(trimTailingSpacesForExternalTableQuery);

1
fe/fe-core/src/main/java/org/apache/doris/system/HeartbeatMgr.java
View File

@ -88,7 +88,6 @@ public class HeartbeatMgr extends MasterDaemon {
tMasterInfo.setHttpPort(Config.http_port);
long flags = heartbeatFlags.getHeartbeatFlags();
tMasterInfo.setHeartbeatFlags(flags);
tMasterInfo.setBeExecVersion(Config.be_exec_version);
masterInfo.set(tMasterInfo);
}