[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=16861938#comment-16861938 ] Piotr Nowojski commented on FLINK-10455: merged commit 765eda1 into apache:release-1.8 merged

[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=16860682#comment-16860682 ] Piotr Nowojski commented on FLINK-10455: merged commit 8364849 to master branch. [~becket_qin]

[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=16856536#comment-16856536 ] sunjincheng commented on FLINK-10455: - Glad to see your update! [~becket_qin] looking forward the

[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=16856494#comment-16856494 ] Jiangjie Qin commented on FLINK-10455: -- Some updates. I think the issue here is still producer

[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=16856486#comment-16856486 ] Jiangjie Qin commented on FLINK-10455: -- Some updates. I think the issue here is still producer

[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=16855490#comment-16855490 ] sunjincheng commented on FLINK-10455: - Yep, sound good!  :) > Potential Kafka producer leak in case

[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=16855489#comment-16855489 ] Jiangjie Qin commented on FLINK-10455: -- [~sunjincheng121] Thanks for the help. I am still working

[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=16855384#comment-16855384 ] sunjincheng commented on FLINK-10455: - Currently, we have added an exception capture for the

[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=16855241#comment-16855241 ] sunjincheng commented on FLINK-10455: - [~becket_qin] is there any update from your side? >

[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=16852565#comment-16852565 ] sunjincheng commented on FLINK-10455: - Hi, [~cslotterback] thanks for your reply. and do not worry

[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=16852563#comment-16852563 ] sunjincheng commented on FLINK-10455: - Hi [~becket_qin], I am very glad that you are willing to help

[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=16851754#comment-16851754 ] Jiangjie Qin commented on FLINK-10455: -- It looks that some further investigation is needed here. I

[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=16851427#comment-16851427 ] Chris Slotterback commented on FLINK-10455: --- [~sunjincheng121] I think it should be solved, as

[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=16851414#comment-16851414 ] sunjincheng commented on FLINK-10455: - Thanks for the quick reply [~azagrebin]! and that make sense

[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=16850803#comment-16850803 ] Andrey Zagrebin commented on FLINK-10455: - [~sunjincheng121] Thanks for asking! Unfortunately, I 

[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=16850556#comment-16850556 ] sunjincheng commented on FLINK-10455: - What is the current situation of this JIRA, is there anyone

[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=16835749#comment-16835749 ] Chris Slotterback commented on FLINK-10455: --- The way I was able to reproduce this was forcing

[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=16689664#comment-16689664 ] ASF GitHub Bot commented on FLINK-10455: pnowojski commented on issue #7107: [FLINK-10455][Kafka

[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=16689665#comment-16689665 ] ASF GitHub Bot commented on FLINK-10455: pnowojski commented on issue #7108: [FLINK-10455][Kafka

[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=16689662#comment-16689662 ] ASF GitHub Bot commented on FLINK-10455: pnowojski closed pull request #7108:

[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=16689659#comment-16689659 ] ASF GitHub Bot commented on FLINK-10455: pnowojski closed pull request #7107:

[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=16688065#comment-16688065 ] ASF GitHub Bot commented on FLINK-10455: azagrebin opened a new pull request #7108:

[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=16688061#comment-16688061 ] ASF GitHub Bot commented on FLINK-10455: azagrebin opened a new pull request #7107:

[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=16686228#comment-16686228 ] ASF GitHub Bot commented on FLINK-10455: azagrebin commented on a change in pull request #6989:

[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=16686224#comment-16686224 ] ASF GitHub Bot commented on FLINK-10455: pnowojski closed pull request #6989:

[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=16685084#comment-16685084 ] ASF GitHub Bot commented on FLINK-10455: azagrebin commented on issue #6989: [FLINK-10455][Kafka

[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=16673441#comment-16673441 ] ASF GitHub Bot commented on FLINK-10455: azagrebin commented on a change in pull request #6989:

[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=16673336#comment-16673336 ] ASF GitHub Bot commented on FLINK-10455: pnowojski commented on issue #6989: [FLINK-10455][Kafka

[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=16673232#comment-16673232 ] ASF GitHub Bot commented on FLINK-10455: pnowojski commented on a change in pull request #6989:

[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=16673230#comment-16673230 ] ASF GitHub Bot commented on FLINK-10455: pnowojski commented on a change in pull request #6989:

[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=16673231#comment-16673231 ] ASF GitHub Bot commented on FLINK-10455: pnowojski commented on a change in pull request #6989:

[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=16673172#comment-16673172 ] ASF GitHub Bot commented on FLINK-10455: azagrebin edited a comment on issue #6989:

[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=16672828#comment-16672828 ] ASF GitHub Bot commented on FLINK-10455: azagrebin commented on issue #6989: [FLINK-10455][Kafka

[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=16672806#comment-16672806 ] ASF GitHub Bot commented on FLINK-10455: StefanRRichter commented on issue #6989:

[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=16671688#comment-16671688 ] ASF GitHub Bot commented on FLINK-10455: azagrebin commented on issue #6989: [FLINK-10455][Kafka

[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=16671675#comment-16671675 ] ASF GitHub Bot commented on FLINK-10455: azagrebin commented on issue #6989: [FLINK-10455][Kafka

[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=16671674#comment-16671674 ] ASF GitHub Bot commented on FLINK-10455: azagrebin opened a new pull request #6989:

[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=16635519#comment-16635519 ] Nico Kruber commented on FLINK-10455: - The following symptom may actually be a follow-up of this