(doris) 08/47: [fix](fe) Fix NPE in FrontendServiceImpl.loadTxnCommit if table is dropped (#31715)

[yiguolei]

This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git

commit d7d8b4ee4a7a20d985f060ca8a63de9d6b822d11
Author: meiyi <myime...@gmail.com>
AuthorDate: Mon Mar 4 17:57:23 2024 +0800

    [fix](fe) Fix NPE in FrontendServiceImpl.loadTxnCommit if table is dropped 
(#31715)
---
 .../src/main/java/org/apache/doris/service/FrontendServiceImpl.java  | 5 ++++-
 1 file changed, 4 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 e8fac1ca4f3..850686116e2 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
@@ -1310,6 +1310,9 @@ public class FrontendServiceImpl implements 
FrontendService.Iface {
     private List<Table> queryLoadCommitTables(TLoadTxnCommitRequest request, 
Database db) throws UserException {
         if (request.isSetTableId() && request.getTableId() > 0) {
             Table table = 
Env.getCurrentEnv().getInternalCatalog().getTableByTableId(request.getTableId());
+            if (table == null) {
+                throw new MetaNotFoundException("unknown table, table_id=" + 
request.getTableId());
+            }
             return Collections.singletonList(table);
         }
 
@@ -1501,7 +1504,7 @@ public class FrontendServiceImpl implements 
FrontendService.Iface {
                 status.addToErrorMsgs("transaction commit successfully, BUT 
data will be visible later");
             }
         } catch (UserException e) {
-            LOG.warn("failed to commit txn: {}: {}", request.getTxnId(), 
e.getMessage());
+            LOG.warn("failed to commit txn: {}", request.getTxnId(), e);
             status.setStatusCode(TStatusCode.ANALYSIS_ERROR);
             status.addToErrorMsgs(e.getMessage());
         } catch (Throwable e) {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org