Jane Chan created FLINK-31404: --------------------------------- Summary: Support extracting source mapping for all RexNode Key: FLINK-31404 URL: https://issues.apache.org/jira/browse/FLINK-31404 Project: Flink Issue Type: Sub-task Components: Table SQL / Planner Affects Versions: 1.17.0, 1.17.1 Reporter: Jane Chan
Currently, `StreamNonDeterministicUpdatePlanVisitor` only supports extracting a limited kind of RexNode to its input node for the Calc. * RexInputRef * RexCall with the operator kind as `AS` and `CAST` It can be optimized to support all kinds of RexNode by FlinkRexUtil#findAllInputRefs. cc [~lincoln.86xy] -- This message was sent by Atlassian Jira (v8.20.10#820010)