[ https://issues.apache.org/jira/browse/FLINK-22601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412935#comment-17412935 ]
xuyangzhong commented on FLINK-22601: ------------------------------------- linkĀ FLINK-22603 > PushWatermarkIntoScan should produce digest created by Expression > ----------------------------------------------------------------- > > Key: FLINK-22601 > URL: https://issues.apache.org/jira/browse/FLINK-22601 > Project: Flink > Issue Type: Improvement > Components: Table SQL / Planner > Reporter: Jingsong Lee > Priority: Minor > Labels: auto-deprioritized-major, pull-request-available > Fix For: 1.14.0 > > > In PushWatermarkIntoTableSourceScanRuleBase, the digest is created by RexNode > instead of Expression, RexNode rely on field index but Expression rely on > field name. > We should adjust it to names. -- This message was sent by Atlassian Jira (v8.3.4#803005)