This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new e3b272b3bc9 [fix](load) fix npe on loadTxn2PCImpl (#31753)
e3b272b3bc9 is described below
commit e3b272b3bc940a6f871f22d633050d7d78893274
Author: Xin Liao <[email protected]>
AuthorDate: Tue Mar 5 11:16:46 2024 +0800
[fix](load) fix npe on loadTxn2PCImpl (#31753)
---
.../src/main/java/org/apache/doris/service/FrontendServiceImpl.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
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 2e855ed79eb..9128220d9b0 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
@@ -1526,10 +1526,12 @@ public class FrontendServiceImpl implements
FrontendService.Iface {
DatabaseTransactionMgr dbTransactionMgr =
Env.getCurrentGlobalTransactionMgr()
.getDatabaseTransactionMgr(database.getId());
TransactionState transactionState =
dbTransactionMgr.getTransactionState(request.getTxnId());
- LOG.debug("txn {} has multi table {}", request.getTxnId(),
transactionState.getTableIdList());
if (transactionState == null) {
throw new UserException("transaction [" + request.getTxnId() + "]
not found");
}
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("txn {} has multi table {}", request.getTxnId(),
transactionState.getTableIdList());
+ }
List<Long> tableIdList = transactionState.getTableIdList();
String txnOperation = request.getOperation().trim();
List<Table> tableList = new ArrayList<>();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
