[FLINK-8325] Add COUNT AGG support constant parameter, i.e. COUNT(*), COUNT(1)

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.5.0
• Fix Version/s: 1.4.1, 1.5.0
• Component/s: Table API & SQL
• Assignee: sunjincheng
• Reporter: sunjincheng
• Created: 28/Dec/17 08:33
• Updated: 21/Jan/18 09:15
• Resolved: 21/Jan/18 09:15

Description

COUNT(1) with Group Window, always output 0.
e.g.
DATA:

val data = List(
    (1L, 1, "Hi"),
    (2L, 2, "Hello"),
    (4L, 2, "Hello"),
    (8L, 3, "Hello world"),
    (16L, 3, "Hello world"))

SQL:

SELECT b, COUNT(1) FROM MyTable GROUP BY Hop(proctime, interval '0.001' SECOND, interval '0.002' SECOND),b

OUTPUT:

1,0,1, 
1,0,1, 
2,0,1,
2,0,1, 
2,0,2, 
3,0,1,
3,0,1

Issue Links

• blocks: FLINK-8355 DataSet Should not union a NULL row for AGG without GROUP BY clause.
• links to: GitHub Pull Request #5241