[jira] [Commented] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-12-05 Thread Jake.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903532#comment-17903532 ] Jake.zhang commented on FLINK-36569: [~hackergin]  `org.apache.flink.connector.kafka

[jira] [Comment Edited] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-10-23 Thread Jake.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892098#comment-17892098 ] Jake.zhang edited comment on FLINK-36569 at 10/23/24 9:32 AM:

[jira] [Commented] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-10-23 Thread Jake.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892098#comment-17892098 ] Jake.zhang commented on FLINK-36569: `org.apache.flink.connector.kafka.sink.KafkaWri

[jira] [Comment Edited] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-10-21 Thread Jake.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891735#comment-17891735 ] Jake.zhang edited comment on FLINK-36569 at 10/22/24 6:34 AM:

[jira] [Commented] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-10-21 Thread Jake.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891735#comment-17891735 ] Jake.zhang commented on FLINK-36569: add schedule close service in `org.apache.flin

[jira] [Updated] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-10-20 Thread Jake.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake.zhang updated FLINK-36569: --- Description: flink kafka connector do't close FlinkKafkaInternalProducer when flink checkpoint succ

[jira] [Updated] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-10-20 Thread Jake.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake.zhang updated FLINK-36569: --- Attachment: image-2024-10-21-14-02-41-823.png > flink kafka connector do not close kafka produer whe

[jira] [Updated] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-10-20 Thread Jake.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake.zhang updated FLINK-36569: --- Description: flink kafka connector do't close FlinkKafkaInternalProducer when flink checkpoint succ

[jira] [Comment Edited] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-10-20 Thread Jake.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891376#comment-17891376 ] Jake.zhang edited comment on FLINK-36569 at 10/21/24 2:24 AM:

[jira] [Commented] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-10-20 Thread Jake.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17891376#comment-17891376 ] Jake.zhang commented on FLINK-36569: Yes,  it create `getRecoveryProducer` each time

[jira] [Created] (FLINK-36569) flink kafka connector do not close kafka produer when it checkpoint success

2024-10-18 Thread Jake.zhang (Jira)
Jake.zhang created FLINK-36569: -- Summary: flink kafka connector do not close kafka produer when it checkpoint success Key: FLINK-36569 URL: https://issues.apache.org/jira/browse/FLINK-36569 Project: Flin

[jira] [Created] (FLINK-33514) FlinkScalaKryoInstantiator class not found in KryoSerializer

2023-11-10 Thread Jake.zhang (Jira)
Jake.zhang created FLINK-33514: -- Summary: FlinkScalaKryoInstantiator class not found in KryoSerializer Key: FLINK-33514 URL: https://issues.apache.org/jira/browse/FLINK-33514 Project: Flink Iss

[jira] [Created] (FLINK-17265) uniform time and timeUnit use

2020-04-20 Thread Jake.zhang (Jira)
Jake.zhang created FLINK-17265: -- Summary: uniform time and timeUnit use Key: FLINK-17265 URL: https://issues.apache.org/jira/browse/FLINK-17265 Project: Flink Issue Type: Wish Componen

[jira] [Created] (FLINK-13346) indexdb reporter parse data type error

2019-07-21 Thread Jake.zhang (JIRA)
Jake.zhang created FLINK-13346: -- Summary: indexdb reporter parse data type error Key: FLINK-13346 URL: https://issues.apache.org/jira/browse/FLINK-13346 Project: Flink Issue Type: Bug Affect