[jira] [Commented] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is g
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496435#comment-17496435
]
Bo Huang commented on FLINK-26204:
--
There are the test.png and TestApp.java. The TestApp.java is running case And
the test.png is result.
The value of ${zookeeper.connect} and ${bootstrap.servers} should be replaced
in TestApp.java.
The Data source should be json type like '\{"uuid":"${rand
string}","timestamp":"2022-02-23 12:00:00","unixTimestamp":164558880}'
When I execute this TestApp.java for more than 10 minutes the bug is reproduced
every time.
By the way, Kafka message data source write speed is 2 / s.
> set table.optimizer.distinct-agg.split.enabled to true and using Window TVF
> CUMULATE to count users, It will appear that the value of the current step
> window time is greater than the value of the next step window time
> -
>
> Key: FLINK-26204
> URL: https://issues.apache.org/jira/browse/FLINK-26204
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
>Affects Versions: 1.14.0, 1.14.3
>Reporter: Bo Huang
>Priority: Blocker
> Attachments: TestApp.java, test.png
>
>
> set table.optimizer.distinct-agg.split.enabled to true
> using Window TVF CUMULATE to count users
> It will appear that the value of the current step window time is greater than
> the value of the next step window time
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Created] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is gre
Bo Huang created FLINK-26204: Summary: set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is greater than the value of the next step window time Key: FLINK-26204 URL: https://issues.apache.org/jira/browse/FLINK-26204 Project: Flink Issue Type: Bug Components: Table SQL / API Affects Versions: 1.14.3, 1.14.0 Reporter: Bo Huang Attachments: TestApp.java, test.png set table.optimizer.distinct-agg.split.enabled to true using Window TVF CUMULATE to count users It will appear that the value of the current step window time is greater than the value of the next step window time -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Created] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic
Bo Huang created FLINK-22300: Summary: Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic Key: FLINK-22300 URL: https://issues.apache.org/jira/browse/FLINK-22300 Project: Flink Issue Type: Improvement Components: API / DataStream Affects Versions: 1.11.3 Reporter: Bo Huang StreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime). The data after Windows process can not be evicted by TimeEvictor of Keyed Windows Beause TimestampedValue have no timestamp value. -- This message was sent by Atlassian Jira (v8.3.4#803005)
