[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881943#comment-16881943 ] Yu Li commented on FLINK-13072: --- Thanks for the confirmation [~srichter], have just opened FLINK-13194 for

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881825#comment-16881825 ] Stefan Richter commented on FLINK-13072: I think it is surely not a bad idea to improve or

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881788#comment-16881788 ] Yu Li commented on FLINK-13072: --- Correct me if I'm wrong, but checking our existing [state

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881665#comment-16881665 ] lynn1.zhang commented on FLINK-13072: - [~srichter] Please help to close, thx. > RocksDBStateBachend

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881149#comment-16881149 ] Stefan Richter commented on FLINK-13072: [~zicat] After reading my previous comment, do you

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16879099#comment-16879099 ] Stefan Richter commented on FLINK-13072: [~zicat] All operators in Flink are assumed to be

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877754#comment-16877754 ] Congxian Qiu(klion26) commented on FLINK-13072: --- I think the problem here is that

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877657#comment-16877657 ] lynn1.zhang commented on FLINK-13072: - I think we can modify the document 

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877656#comment-16877656 ] Congxian Qiu(klion26) commented on FLINK-13072: --- I think currently we assume that all

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877608#comment-16877608 ] lynn1.zhang commented on FLINK-13072: - from beginning, I also think the {{input.iterator()}} is not

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877586#comment-16877586 ] Yun Tang commented on FLINK-13072: -- [~zicat] After a quick look, I believe this is not a