[
https://issues.apache.org/jira/browse/FLINK-13004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873994#comment-16873994
]
Jark Wu commented on FLINK-13004:
-
[~yunta] (y)
> Correct the logic of needToCleanupState in
>
[
https://issues.apache.org/jira/browse/FLINK-13004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873815#comment-16873815
]
Yun Tang commented on FLINK-13004:
--
[~jark], actually, the {{timestamp}} passed in was wrapper
[
https://issues.apache.org/jira/browse/FLINK-13004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873756#comment-16873756
]
Jark Wu commented on FLINK-13004:
-
I think the {{timestamp}} parameter should be primitive long. Thanks
