Skip to content

Commit

Permalink
[fix](Nereids) fix create routine load forward strategy (#45253)
Browse files Browse the repository at this point in the history
  • Loading branch information
LiBinfeng-01 authored Dec 12, 2024
1 parent d775eb7 commit e70175f
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
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;
Expand Down Expand Up @@ -68,7 +68,7 @@
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) {
Expand Down

0 comments on commit e70175f

Please sign in to comment.