You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by da...@apache.org on 2023/06/06 07:46:55 UTC
[doris] branch master updated: [fix](load) fix unified load redirect status delegate error (#20467)
This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 48021366bf [fix](load) fix unified load redirect status delegate error (#20467)
48021366bf is described below
commit 48021366bffcdcad264b76a648f8758d7e9ba309
Author: lvshaokang <lv...@hotmail.com>
AuthorDate: Tue Jun 6 15:46:48 2023 +0800
[fix](load) fix unified load redirect status delegate error (#20467)
---
.../src/main/java/org/apache/doris/analysis/UnifiedLoadStmt.java | 5 +++++
.../src/test/java/org/apache/doris/analysis/LoadStmtTest.java | 8 ++++++++
2 files changed, 13 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/UnifiedLoadStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/UnifiedLoadStmt.java
index 4b395f1f5e..8a58ee9523 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/UnifiedLoadStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/UnifiedLoadStmt.java
@@ -64,4 +64,9 @@ public class UnifiedLoadStmt extends DdlStmt {
public StatementBase getProxyStmt() {
return proxyStmt;
}
+
+ @Override
+ public RedirectStatus getRedirectStatus() {
+ return proxyStmt.getRedirectStatus();
+ }
}
diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java
index cd8fc4be26..59070dc80c 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/LoadStmtTest.java
@@ -239,6 +239,14 @@ public class LoadStmtTest {
stmt.analyze(analyzer);
Assert.assertNull(stmt.getLabel().getDbName());
Assert.assertEquals(EtlJobType.LOCAL_FILE, stmt.getEtlJobType());
+
+ // unified load stmt
+ UnifiedLoadStmt unifiedStmt = UnifiedLoadStmt.buildMysqlLoadStmt(desc, Maps.newHashMap(), "");
+ Config.mysql_load_server_secure_path = "/";
+ unifiedStmt.analyze(analyzer);
+ Assert.assertTrue(unifiedStmt.getProxyStmt() instanceof LoadStmt);
+ Assert.assertNull(((LoadStmt) unifiedStmt.getProxyStmt()).getLabel().getDbName());
+ Assert.assertEquals(unifiedStmt.getRedirectStatus(), RedirectStatus.NO_FORWARD);
}
@Test
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org