[jira] [Created] (FLINK-9287) KafkaProducer011 seems to leak threads when not in exactly-once mode

Christopher Ng created FLINK-9287: - Summary: KafkaProducer011 seems to leak threads when not in exactly-once mode Key: FLINK-9287 URL: https://issues.apache.org/jira/browse/FLINK-9287 Project: Flink

[jira] [Created] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

Christopher Ng created FLINK-9295: - Summary: FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode Key: FLINK-9295 URL: https://issues.apache.org/jira/browse/FLINK-9295

[jira] [Updated] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

[ https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher Ng updated FLINK-9295: -- Description: {{FlinkKafkaProducer011}} can throw {{ProducerFencedExceptions}} if multiple sinks

[jira] [Updated] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode

[ https://issues.apache.org/jira/browse/FLINK-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher Ng updated FLINK-9295: -- Description: {{FlinkKafkaProducer011}} can throw {{ProducerFencedExceptions}} if multiple sinks

[jira] [Commented] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16413781#comment-16413781 ] Christopher Ng commented on FLINK-8836: --- I don't think they are thread-safe:  https:

[jira] [Commented] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415826#comment-16415826 ] Christopher Ng commented on FLINK-8836: --- [~StephanEwen] i asked on the Kryo mailing

[jira] [Comment Edited] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers

[ https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415826#comment-16415826 ] Christopher Ng edited comment on FLINK-8836 at 3/27/18 3:51 PM:

[jira] [Created] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers

Christopher Ng created FLINK-9151: - Summary: standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers Key: FLINK-9151 URL: https://issues.apache.org/jira/browse/FLINK-9151

[jira] [Updated] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers

[ https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher Ng updated FLINK-9151: -- Affects Version/s: 1.4.1 > standalone cluster scripts should pass FLINK_CONF_DIR to job manager

[jira] [Updated] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers

[ https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher Ng updated FLINK-9151: -- Component/s: Startup Shell Scripts > standalone cluster scripts should pass FLINK_CONF_DIR to jo

[jira] [Closed] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers

[ https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher Ng closed FLINK-9151. - Resolution: Won't Fix This can be handled by `env.ssh.opts` provided your target servers allow you