(doris) branch master updated: [Chore](load) return error reason when database/table not founded when stream load (#38967)

[panxiaolei]

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

panxiaolei 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 3aadf92e559 [Chore](load) return error reason when database/table not 
founded when stream load (#38967)
3aadf92e559 is described below

commit 3aadf92e55939da546e7323140bef8d61ca1a983
Author: Pxl <pxl...@qq.com>
AuthorDate: Wed Aug 7 15:14:31 2024 +0800

    [Chore](load) return error reason when database/table not founded when 
stream load (#38967)
    
    ## Proposed changes
    return error reason when database/table not founded when stream load
---
 .../main/java/org/apache/doris/httpv2/rest/LoadAction.java | 14 ++++++++++++--
 1 file changed, 12 insertions(+), 2 deletions(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/LoadAction.java 
b/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/LoadAction.java
index 8bdc88a9c22..c2d50460ea4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/LoadAction.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/LoadAction.java
@@ -62,6 +62,7 @@ import java.net.InetAddress;
 import java.net.URI;
 import java.util.Enumeration;
 import java.util.List;
+import java.util.Optional;
 import java.util.Set;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
@@ -293,8 +294,17 @@ public class LoadAction extends RestBaseController {
                     return new RestBaseResult(e.getMessage());
                 }
             } else {
-                long tableId = ((OlapTable) ((Database) 
Env.getCurrentEnv().getCurrentCatalog().getDb(dbName)
-                        .get()).getTable(tableName).get()).getId();
+                Optional<?> database = 
Env.getCurrentEnv().getCurrentCatalog().getDb(dbName);
+                if (!database.isPresent()) {
+                    return new RestBaseResult("Database not founded.");
+                }
+
+                Optional<?> olapTable = ((Database) 
database.get()).getTable(tableName);
+                if (!olapTable.isPresent()) {
+                    return new RestBaseResult("OlapTable not founded.");
+                }
+
+                long tableId = ((OlapTable) olapTable.get()).getId();
                 redirectAddr = selectRedirectBackend(request, groupCommit, 
tableId);
             }
 


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