diff --git a/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java b/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java index c006906c0a2fcf9..134c4f50565af5b 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java @@ -594,12 +594,6 @@ public void updateMultiTableRunningTransactionTableIds(Long dbId, Long transacti throw new UserException(NOT_SUPPORTED_MSG); } - @Override - public void putTransactionTableNames(Long dbId, Long transactionId, List tableIds) - throws Exception { - throw new Exception(NOT_SUPPORTED_MSG); - } - @Override public TWaitingTxnStatusResult getWaitingTxnStatus(TWaitingTxnStatusRequest request) throws AnalysisException, TimeoutException { diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java index 2c5345cbaac9116..2bd64d3039bce8c 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java +++ b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java @@ -1924,8 +1924,6 @@ public TStreamLoadMultiTablePutResult streamLoadMultiTablePut(TStreamLoadPutRequ } multiTableFragmentInstanceIdIndexMap.put(request.getTxnId(), ++index); } - Env.getCurrentGlobalTransactionMgr() - .putTransactionTableNames(db.getId(), request.getTxnId(), tableIds); LOG.debug("receive stream load multi table put request result: {}", result); } catch (Throwable e) { LOG.warn("catch unknown result.", e); diff --git a/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java b/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java index e772b28ade47929..fd48b974544193c 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java @@ -2246,17 +2246,6 @@ private static String getStackTrace(Thread t) { return msgBuilder.toString(); } - protected void putTransactionTableNames(long transactionId, List tableIds) { - if (CollectionUtils.isEmpty(tableIds)) { - return; - } - if (multiTableRunningTransactionTableIdMaps.contains(transactionId)) { - multiTableRunningTransactionTableIdMaps.get(transactionId).addAll(tableIds); - return; - } - multiTableRunningTransactionTableIdMaps.put(transactionId, tableIds); - } - /** * Update transaction table ids by transaction id. * it's used for multi table transaction. diff --git a/fe/fe-core/src/main/java/org/apache/doris/transaction/GlobalTransactionMgr.java b/fe/fe-core/src/main/java/org/apache/doris/transaction/GlobalTransactionMgr.java index 84125950a4e7b2d..f755d148c9203bc 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/transaction/GlobalTransactionMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/transaction/GlobalTransactionMgr.java @@ -455,12 +455,6 @@ public void updateMultiTableRunningTransactionTableIds(Long dbId, Long transacti getDatabaseTransactionMgr(dbId).updateMultiTableRunningTransactionTableIds(transactionId, tableIds); } - @Override - public void putTransactionTableNames(Long dbId, Long transactionId, List tableIds) - throws Exception { - getDatabaseTransactionMgr(dbId).putTransactionTableNames(transactionId, tableIds); - } - @Override public TWaitingTxnStatusResult getWaitingTxnStatus(TWaitingTxnStatusRequest request) throws AnalysisException, TimeoutException { diff --git a/fe/fe-core/src/main/java/org/apache/doris/transaction/GlobalTransactionMgrIface.java b/fe/fe-core/src/main/java/org/apache/doris/transaction/GlobalTransactionMgrIface.java index 6890222f1824b66..489b4240d0d0543 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/transaction/GlobalTransactionMgrIface.java +++ b/fe/fe-core/src/main/java/org/apache/doris/transaction/GlobalTransactionMgrIface.java @@ -122,9 +122,6 @@ public boolean isPreviousTransactionsFinished(long endTransactionId, long dbId, public void updateMultiTableRunningTransactionTableIds(Long dbId, Long transactionId, List tableIds) throws UserException; - public void putTransactionTableNames(Long dbId, Long transactionId, List tableIds) - throws Exception; - public TWaitingTxnStatusResult getWaitingTxnStatus(TWaitingTxnStatusRequest request) throws AnalysisException, TimeoutException;