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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
