This is an automated email from the ASF dual-hosted git repository.
starocean999 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 e70175fc2d5 [fix](Nereids) fix create routine load forward strategy
(#45253)
e70175fc2d5 is described below
commit e70175fc2d5d53ffe5b7b00c7c634ba6f3c3044e
Author: LiBinfeng <[email protected]>
AuthorDate: Thu Dec 12 10:34:29 2024 +0800
[fix](Nereids) fix create routine load forward strategy (#45253)
---
.../nereids/trees/plans/commands/load/CreateRoutineLoadCommand.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/load/CreateRoutineLoadCommand.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/load/CreateRoutineLoadCommand.java
index da7ab86c17a..5632bdc2585 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/load/CreateRoutineLoadCommand.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/load/CreateRoutineLoadCommand.java
@@ -21,7 +21,7 @@ import org.apache.doris.analysis.CreateRoutineLoadStmt;
import org.apache.doris.catalog.Env;
import org.apache.doris.nereids.trees.plans.PlanType;
import org.apache.doris.nereids.trees.plans.commands.Command;
-import org.apache.doris.nereids.trees.plans.commands.NoForward;
+import org.apache.doris.nereids.trees.plans.commands.ForwardWithSync;
import
org.apache.doris.nereids.trees.plans.commands.info.CreateRoutineLoadInfo;
import org.apache.doris.nereids.trees.plans.visitor.PlanVisitor;
import org.apache.doris.qe.ConnectContext;
@@ -68,7 +68,7 @@ import java.util.Objects;
type of routine load:
KAFKA
*/
-public class CreateRoutineLoadCommand extends Command implements NoForward {
+public class CreateRoutineLoadCommand extends Command implements
ForwardWithSync {
CreateRoutineLoadInfo createRoutineLoadInfo;
public CreateRoutineLoadCommand(CreateRoutineLoadInfo
createRoutineLoadInfo) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
