morrySnow commented on code in PR #32263:
URL: https://github.com/apache/doris/pull/32263#discussion_r1525732858
##########
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVCache.java:
##########
@@ -64,11 +64,8 @@ public static MTMVCache from(MTMV mtmv, ConnectContext
connectContext) {
Plan originPlan = planner.plan(unboundMvPlan, PhysicalProperties.ANY,
ExplainLevel.REWRITTEN_PLAN);
Plan mvPlan = originPlan.accept(new DefaultPlanRewriter<Object>() {
@Override
- public Plan visit(Plan plan, Object context) {
- if (plan instanceof LogicalResultSink) {
- return ((LogicalResultSink<Plan>) plan).child();
- }
- return super.visit(plan, context);
+ public Plan visitLogicalResultSink(LogicalResultSink<? extends
Plan> logicalResultSink, Object context) {
+ return logicalResultSink.child().accept(this, context);
Review Comment:
file sink need keep order too. so u need override visitLogicalFileSink
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
