[
https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingxing Di updated FLINK-10674:
Attachment: screenshot-1.png
> Fix handling of retractions after clean up
> --
[
https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10674:
-
Description:
Our online Flink Job run about a week，job contain sql ：
{code:java}
select `time`,
[
https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10674:
-
Summary: Fix handling of retractions after clean up (was:
DistinctAccumulator.remove lead to NP
