This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new a80edb203a5 [fix](group commit) remove unused code (#44015)
a80edb203a5 is described below
commit a80edb203a5ea5e96e9d88cb8a5237818b938e1d
Author: meiyi <[email protected]>
AuthorDate: Fri Nov 15 19:57:30 2024 +0800
[fix](group commit) remove unused code (#44015)
remove unused code because the select be strategy is moved to
GroupCommitManager
---
fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java | 9 ---------
1 file changed, 9 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
index cbae761596d..5e0716da7d7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectContext.java
@@ -236,7 +236,6 @@ public class ConnectContext {
private Map<String, String> resultAttachedInfo = Maps.newHashMap();
private String workloadGroupName = "";
- private Map<Long, Backend> insertGroupCommitTableToBeMap = new HashMap<>();
private boolean isGroupCommit;
private TResultSinkType resultSinkType = TResultSinkType.MYSQL_PROTOCAL;
@@ -1329,14 +1328,6 @@ public class ConnectContext {
return this.workloadGroupName;
}
- public void setInsertGroupCommit(long tableId, Backend backend) {
- insertGroupCommitTableToBeMap.put(tableId, backend);
- }
-
- public Backend getInsertGroupCommit(long tableId) {
- return insertGroupCommitTableToBeMap.get(tableId);
- }
-
public boolean isSkipAuth() {
return skipAuth;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
