[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-07 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172934#comment-17172934 ] Roman Khachatryan commented on FLINK-18796: --- During the offline discussion, we agreed that

[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-06 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172778#comment-17172778 ] Zhijiang commented on FLINK-18796: -- Merged in master: 33bdc978a059c50ec55b8f24d40039d13a6b78e7 >

[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171766#comment-17171766 ] Chesnay Schepler commented on FLINK-18796: -- Isn't the same true for the FlinkKinesisProducer?

[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-05 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171753#comment-17171753 ] Roman Khachatryan commented on FLINK-18796: --- CassandraSinkBase is a bit different in that it

[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171678#comment-17171678 ] Chesnay Schepler commented on FLINK-18796: -- A callback accessing internal state initialized

[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-03 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170437#comment-17170437 ] Roman Khachatryan commented on FLINK-18796: --- I'm not sure whether it's actually a problem,

[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-03 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170419#comment-17170419 ] Chesnay Schepler commented on FLINK-18796: -- Why would this be a problem _now_? We've used this

[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-03 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170122#comment-17170122 ] Robert Metzger commented on FLINK-18796: [~tzulitai] or [~thw] I was mentioned in this ticket,