Baozhu Zhao created FLINK-35885:
-----------------------------------
Summary: SlicingWindowOperator should not process watermark with
proctime
Key: FLINK-35885
URL: https://issues.apache.org/jira/browse/FLINK-35885
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 1.17.2, 1.13.6
Environment: flink 1.13.6 or flink 1.17.2
Reporter: Baozhu Zhao
We have discovered an unexpected case where abnormal data with a count of 0
occurs when performing proctime window aggregation on data with a watermark,
The SQL is as follows
{code:sql}
CREATE TABLE s1 (
id INT,
event_time TIMESTAMP(3),
name string,
proc_time AS PROCTIME (),
WATERMARK FOR event_time AS event_time - INTERVAL '10' SECOND
)
WITH
('connector' = 'my-source')
;
SELECT
*
FROM
(
SELECT
name,
COUNT(id) AS total_count,
window_start,
window_end
FROM
TABLE (
TUMBLE (
TABLE s1,
DESCRIPTOR (proc_time),
INTERVAL '30' SECONDS
)
)
GROUP BY
window_start,
window_end,
name
)
WHERE
total_count = 0;
{code}
For detailed test code, please refer to xxx
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
