[
https://issues.apache.org/jira/browse/FLINK-18204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138071#comment-17138071
]
shengsheng lin commented on FLINK-18204:
Thanks [~yunta] , we solved this problem by adding lock
[
https://issues.apache.org/jira/browse/FLINK-18204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130784#comment-17130784
]
Yun Tang commented on FLINK-18204:
--
[~shengsheng] I'm afraid it's not so easy to do as current Flink
[
https://issues.apache.org/jira/browse/FLINK-18204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130399#comment-17130399
]
shengsheng lin commented on FLINK-18204:
[~yunta] It seems that we found the cause of the
[
https://issues.apache.org/jira/browse/FLINK-18204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129179#comment-17129179
]
Yun Tang commented on FLINK-18204:
--
[~shengsheng]
After digging into the code and I think [this
[
https://issues.apache.org/jira/browse/FLINK-18204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129063#comment-17129063
]
shengsheng lin commented on FLINK-18204:
[~yunta] We called registerEventTimeTimer of
[
https://issues.apache.org/jira/browse/FLINK-18204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129043#comment-17129043
]
Yun Tang commented on FLINK-18204:
--
[~shengsheng] What did you mean "internal timer"? Have you ever
[
https://issues.apache.org/jira/browse/FLINK-18204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129037#comment-17129037
]
shengsheng lin commented on FLINK-18204:
Sorry, we used version 1.6. At the same time, we used
[
https://issues.apache.org/jira/browse/FLINK-18204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129007#comment-17129007
]
Yun Tang commented on FLINK-18204:
--
This is really weird as we would not put null into the timer queue.
