This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new e5f3c86511f branch-3.1: [fix](stream loader) do not redirect to https
for stream load #50009 (#52046)
e5f3c86511f is described below
commit e5f3c86511f5dd9bc5d218483b9698cdfc0af488
Author: minghong <[email protected]>
AuthorDate: Fri Jun 20 17:18:40 2025 +0800
branch-3.1: [fix](stream loader) do not redirect to https for stream load
#50009 (#52046)
pick #50009
---
.../main/java/org/apache/doris/httpv2/rest/LoadAction.java | 14 --------------
1 file changed, 14 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 2f9efc1ed1b..8a8935d808e 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
@@ -87,10 +87,6 @@ public class LoadAction extends RestBaseController {
@RequestMapping(path = "/api/{" + DB_KEY + "}/{" + TABLE_KEY + "}/_load",
method = RequestMethod.PUT)
public Object load(HttpServletRequest request, HttpServletResponse
response,
@PathVariable(value = DB_KEY) String db, @PathVariable(value =
TABLE_KEY) String table) {
- if (needRedirect(request.getScheme())) {
- return redirectToHttps(request);
- }
-
if (Config.disable_mini_load) {
ResponseEntity entity = ResponseEntityBuilder.notFound("The mini
load operation has been"
+ " disabled by default, if you need to add
disable_mini_load=false in fe.conf.");
@@ -128,10 +124,6 @@ public class LoadAction extends RestBaseController {
}
}
}
- if (needRedirect(request.getScheme())) {
- return redirectToHttps(request);
- }
-
String authToken = request.getHeader("token");
// if auth token is not null, check it first
if (!Strings.isNullOrEmpty(authToken)) {
@@ -246,9 +238,6 @@ public class LoadAction extends RestBaseController {
HttpServletResponse response,
@PathVariable(value = DB_KEY) String db) {
LOG.info("streamload action 2PC, db: {}, headers: {}", db,
getAllHeaders(request));
- if (needRedirect(request.getScheme())) {
- return redirectToHttps(request);
- }
executeCheckPassword(request, response);
return executeStreamLoad2PC(request, db);
@@ -260,9 +249,6 @@ public class LoadAction extends RestBaseController {
@PathVariable(value = DB_KEY) String db,
@PathVariable(value = TABLE_KEY) String table) {
LOG.info("streamload action 2PC, db: {}, tbl: {}, headers: {}", db,
table, getAllHeaders(request));
- if (needRedirect(request.getScheme())) {
- return redirectToHttps(request);
- }
executeCheckPassword(request, response);
return executeStreamLoad2PC(request, db);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
