[jira] [Created] (FLINK-19460) AWS Kinesis Producer EXACTLY_ONCE semantic

Chris Slotterback created FLINK-19460: - Summary: AWS Kinesis Producer EXACTLY_ONCE semantic Key: FLINK-19460 URL: https://issues.apache.org/jira/browse/FLINK-19460 Project: Flink Issue T

[jira] [Comment Edited] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851427#comment-16851427 ] Chris Slotterback edited comment on FLINK-10455 at 5/30/19 12:30 AM: -

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851427#comment-16851427 ] Chris Slotterback commented on FLINK-10455: --- [~sunjincheng121] I think it shou

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835749#comment-16835749 ] Chris Slotterback commented on FLINK-10455: --- The way I was able to reproduce t

[jira] [Closed] (FLINK-12448) FlinkKafkaProducer late closure after class loader

[ https://issues.apache.org/jira/browse/FLINK-12448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Slotterback closed FLINK-12448. - Resolution: Duplicate > FlinkKafkaProducer late closure after class loader > ---

[jira] [Created] (FLINK-12448) FlinkKafkaProducer late closure after class loader

Chris Slotterback created FLINK-12448: - Summary: FlinkKafkaProducer late closure after class loader Key: FLINK-12448 URL: https://issues.apache.org/jira/browse/FLINK-12448 Project: Flink

[jira] [Comment Edited] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16788247#comment-16788247 ] Chris Slotterback edited comment on FLINK-11654 at 3/8/19 7:59 PM: ---

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16788247#comment-16788247 ] Chris Slotterback commented on FLINK-11654: --- I do think that if setting the {{