[ https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16309715#comment-16309715 ]
sunjincheng commented on FLINK-8325: ------------------------------------ After I check the detail I find that only `CountAggFunction ` has this problem. The reason is calcite do the argument optimize. when meet {{COUNT(*)}} or {{COUNT(1)}}, calcite will ignore the param,so flink will get {{COUNT()}}. we should add {{COUNT()}} in {{CountAggFunction}} and {{AggregateUtil}}. > Add support for constant parameters in GROUP WINDOW aggregate > ------------------------------------------------------------- > > Key: FLINK-8325 > URL: https://issues.apache.org/jira/browse/FLINK-8325 > Project: Flink > Issue Type: Bug > Components: Table API & SQL > Affects Versions: 1.5.0 > Reporter: sunjincheng > Assignee: sunjincheng > > COUNT(1) with Group Window, always output 0. > e.g. > DATA: > {code} > val data = List( > (1L, 1, "Hi"), > (2L, 2, "Hello"), > (4L, 2, "Hello"), > (8L, 3, "Hello world"), > (16L, 3, "Hello world")) > {code} > SQL: > {code} > SELECT b, COUNT(1) FROM MyTable GROUP BY Hop(proctime, interval '0.001' > SECOND, interval '0.002' SECOND),b > {code} > OUTPUT: > {code} > 1,0,1, > 1,0,1, > 2,0,1, > 2,0,1, > 2,0,2, > 3,0,1, > 3,0,1 > {code} -- This message was sent by Atlassian JIRA (v6.4.14#64029)