[ https://issues.apache.org/jira/browse/FLINK-33691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yunhong Zheng updated FLINK-33691: ---------------------------------- Description: Now, PushLocalAggIntoScanRule cannot push down 'count( * )/count(1)/count(column not null)', but it can push down count(column nullable). The reason is that count( * ) and count( 1 ) will be optimized to a scan with calc as '0 AS $f0' to reduce read cost, which will not match the push down rule (was: Now, PushLocalAggIntoScanRule cannot push down 'count(*)/count(1)/count(column not null)', but it can push down count(column nullable). The reason is that count(*) and count(n) will be optimized to a scan with calc as '0 AS $f0' to reduce read cost, which will not match the push down rule) > Support agg push down for 'count(*)/count(1)/count(column not null)' > -------------------------------------------------------------------- > > Key: FLINK-33691 > URL: https://issues.apache.org/jira/browse/FLINK-33691 > Project: Flink > Issue Type: Improvement > Components: Table SQL / Planner > Affects Versions: 1.19.0 > Reporter: Yunhong Zheng > Priority: Major > Fix For: 1.19.0 > > > Now, PushLocalAggIntoScanRule cannot push down 'count( * > )/count(1)/count(column not null)', but it can push down count(column > nullable). The reason is that count( * ) and count( 1 ) will be optimized to > a scan with calc as '0 AS $f0' to reduce read cost, which will not match the > push down rule -- This message was sent by Atlassian Jira (v8.20.10#820010)