Hi Xinghalo, 看起来是个 codegen bug， 能帮忙在 JIRA 中建一个 issue 么？最好能附上您的例子。
Best, Jark On Tue, 7 Apr 2020 at 14:22, 111 <[email protected]> wrote: > Hi， > 原来如此，是搭配使用的。 > > > 不过加上条件后，提示无法进行剪枝 > Caused by: org.apache.flink.table.api.TableException: This calc has no > useful projection and no filter. It should be removed by CalcRemoveRule. at > org.apache.flink.table.planner.codegen.CalcCodeGenerator$.generateProcessCode(CalcCodeGenerator.scala:176) > at > org.apache.flink.table.planner.codegen.CalcCodeGenerator$.generateCalcOperator(CalcCodeGenerator.scala:49) > at > org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecCalc.translateToPlanInternal(StreamExecCalc.scala:77) > at > org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecCalc.translateToPlanInternal(StreamExecCalc.scala:39) > at > org.apache.flink.table.planner.plan.nodes.exec.ExecNode$class.translateToPlan(ExecNode.scala:58)必须强制加上一个where > 1=1才能走通。select * from ( SELECT member_id, category_id, c, row_number() over > (PARTITION BY member_id ORDER BY c) AS rn FROM window_v where 1=1 ) where > rn <= 5 > Best,Xinghalo
