[ https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16012382#comment-16012382 ]
ASF GitHub Bot commented on FLINK-6583: --------------------------------------- Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3919#discussion_r116727812 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamGroupWindowAggregate.scala --- @@ -296,6 +322,8 @@ object DataStreamGroupWindowAggregate { case SlidingGroupWindow(_, timeField, size, slide) if isProctimeAttribute(timeField) && isRowCountLiteral(size)=> stream.countWindowAll(toLong(size), toLong(slide)) + .evictor(CountEvictor.of(toLong(size))) --- End diff -- same as above > Enable QueryConfig in count base GroupWindow > -------------------------------------------- > > Key: FLINK-6583 > URL: https://issues.apache.org/jira/browse/FLINK-6583 > Project: Flink > Issue Type: New Feature > Components: Table API & SQL > Affects Versions: 1.3.0, 1.4.0 > Reporter: sunjincheng > Assignee: sunjincheng > > Enable QueryConfig in count base GroupWindow by Add a custom Trigger > `CountTriggerWithCleanupState`. See more in FLINK-6491. -- This message was sent by Atlassian JIRA (v6.3.15#6346)