Hi, I have implement myRule that implement ConverterRule,and define my DataStreamNode like
public class DataStreamCalc extends Calc implements DataStreamRel { public DataStreamCalc(RelOptCluster cluster, RelTraitSet traits, List<RelHint> hints, RelNode child, RexProgram program) { super(cluster, traits, hints, child, program); } /** * eg: use for merge calc */ @Override public Calc copy(RelTraitSet traitSet, RelNode child, RexProgram program) { return new DataStreamCalc(getCluster(),getTraitSet(),hints,input,getProgram()); } @Override public RelOptCost computeSelfCost(RelOptPlanner planner, RelMetadataQuery mq) { return Costs.defaultCost(); } @Override public DataStream<Row> translateToPlan(FlinkPlanner planner) { return null; } } ,I hava add ProjectToCalcRule and FilterToCalcRule. however it still can not find BestPlan. and the stackTrace like the attachment. laughing.sh...@qq.com