Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.17.0, 1.17.1
Description
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
Attachments
Issue Links
- links to