[jira] [Commented] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290261#comment-17290261 ] Kenzyme Le commented on FLINK-21427: *Would you like to provide a fix for this issue?* Yes! >

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290241#comment-17290241 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 8:27 PM: -- Hi

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290241#comment-17290241 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 8:21 PM: -- Hi

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290241#comment-17290241 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 8:20 PM: -- Hi

[jira] [Commented] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290241#comment-17290241 ] Kenzyme Le commented on FLINK-21427: *Were you able to verify this (savepoint case) by removing the

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290198#comment-17290198 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 7:01 PM: -- Hi

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290198#comment-17290198 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 7:00 PM: -- Hi

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290198#comment-17290198 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 6:59 PM: -- Hi

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290198#comment-17290198 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 6:59 PM: -- Hi

[jira] [Commented] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290198#comment-17290198 ] Kenzyme Le commented on FLINK-21427: Hi [~roman_khachatryan] , I was able to successfully reproduce

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289317#comment-17289317 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 5:56 PM: -- Hi Roman,

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289317#comment-17289317 ] Kenzyme Le edited comment on FLINK-21427 at 2/23/21, 8:38 PM: -- Hi Roman,

[jira] [Commented] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289317#comment-17289317 ] Kenzyme Le commented on FLINK-21427: Hi Roman, *Did you issue stop-with-savepoint command?* Yes,

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289266#comment-17289266 ] Kenzyme Le edited comment on FLINK-21427 at 2/23/21, 7:52 PM: -- *I'd verify

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289266#comment-17289266 ] Kenzyme Le edited comment on FLINK-21427 at 2/23/21, 7:19 PM: -- *I'd verify

[jira] [Commented] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289266#comment-17289266 ] Kenzyme Le commented on FLINK-21427: *I'd verify that this checkpoint wasn't already "completed" by

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289147#comment-17289147 ] Kenzyme Le edited comment on FLINK-21427 at 2/23/21, 5:12 PM: -- My other

[jira] [Comment Edited] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289147#comment-17289147 ] Kenzyme Le edited comment on FLINK-21427 at 2/23/21, 4:49 PM: -- My other

[jira] [Commented] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289147#comment-17289147 ] Kenzyme Le commented on FLINK-21427: My other hunch about this is that my Pojos did not explicitly

[jira] [Commented] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289103#comment-17289103 ] Kenzyme Le commented on FLINK-21427: Hello [~roman_khachatryan] , I implemented the

[jira] [Commented] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288801#comment-17288801 ] Kenzyme Le commented on FLINK-21427: Hello [~roman_khachatryan], Any idea on possible causes on

[jira] [Commented] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288795#comment-17288795 ] Kenzyme Le commented on FLINK-21427: I'm wondering if

[jira] [Updated] (FLINK-21427) Recovering from savepoint key does not exist in S3

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-21427: --- Summary: Recovering from savepoint key does not exist in S3 (was: Recovering from savepoint key

[jira] [Updated] (FLINK-21427) Recovering from savepoint key does not exist

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-21427: --- Summary: Recovering from savepoint key does not exist (was: Recovering from savepoint unable to

[jira] [Updated] (FLINK-21427) Recovering from savepoint unable to commit

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-21427: --- Description: Hi, I was able to stop and generate a savepoint successfully, but resuming the job

[jira] [Updated] (FLINK-21427) Recovering from savepoint unable to commit

[ https://issues.apache.org/jira/browse/FLINK-21427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-21427: --- Description: Hi, I was able to stop and generate a savepoint successfully, but resuming the job

[jira] [Created] (FLINK-21427) Recovering from savepoint unable to commit

Kenzyme Le created FLINK-21427: -- Summary: Recovering from savepoint unable to commit Key: FLINK-21427 URL: https://issues.apache.org/jira/browse/FLINK-21427 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-19593) FlinkKafkaInternalProducer should be @Internal annotation ?

[ https://issues.apache.org/jira/browse/FLINK-19593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-19593: --- Description: Hello, Seems like [

[jira] [Updated] (FLINK-19593) FlinkKafkaInternalProducer should be @Internal annotation ?

[ https://issues.apache.org/jira/browse/FLINK-19593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-19593: --- Component/s: Connectors / Kafka > FlinkKafkaInternalProducer should be @Internal annotation ? >

[jira] [Updated] (FLINK-19591) Missing @Internal annotation SimpleJdbcConnectionProvider

[ https://issues.apache.org/jira/browse/FLINK-19591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-19591: --- Component/s: Connectors / JDBC > Missing @Internal annotation SimpleJdbcConnectionProvider >

[jira] [Updated] (FLINK-19593) FlinkKafkaInternalProducer should be @Internal annotation ?

[ https://issues.apache.org/jira/browse/FLINK-19593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-19593: --- Description: Hello, Seems like [

[jira] [Updated] (FLINK-19593) FlinkKafkaInternalProducer should be @Internal annotation ?

[ https://issues.apache.org/jira/browse/FLINK-19593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-19593: --- Issue Type: Improvement (was: Bug) > FlinkKafkaInternalProducer should be @Internal annotation ? >

[jira] [Updated] (FLINK-19591) Missing @Internal annotation SimpleJdbcConnectionProvider

[ https://issues.apache.org/jira/browse/FLINK-19591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-19591: --- Issue Type: Improvement (was: Bug) > Missing @Internal annotation SimpleJdbcConnectionProvider >

[jira] [Created] (FLINK-19593) FlinkKafkaInternalProducer should be @Internal annotation ?

Kenzyme Le created FLINK-19593: -- Summary: FlinkKafkaInternalProducer should be @Internal annotation ? Key: FLINK-19593 URL: https://issues.apache.org/jira/browse/FLINK-19593 Project: Flink

[jira] [Updated] (FLINK-19593) FlinkKafkaInternalProducer should be @Internal annotation ?

[ https://issues.apache.org/jira/browse/FLINK-19593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-19593: --- Labels: (was: pull-request-available) > FlinkKafkaInternalProducer should be @Internal annotation

[jira] [Updated] (FLINK-19591) Missing @Internal annotation SimpleJdbcConnectionProvider

[ https://issues.apache.org/jira/browse/FLINK-19591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-19591: --- Priority: Minor (was: Major) > Missing @Internal annotation SimpleJdbcConnectionProvider >

[jira] [Created] (FLINK-19591) Missing @Internal annotation SimpleJdbcConnectionProvider

Kenzyme Le created FLINK-19591: -- Summary: Missing @Internal annotation SimpleJdbcConnectionProvider Key: FLINK-19591 URL: https://issues.apache.org/jira/browse/FLINK-19591 Project: Flink Issue

[jira] [Commented] (FLINK-15578) Implement exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209035#comment-17209035 ] Kenzyme Le commented on FLINK-15578: Thank you for the update [~roman_khachatryan] . I'll look into

[jira] [Commented] (FLINK-15578) Implement exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204063#comment-17204063 ] Kenzyme Le commented on FLINK-15578: Hello [~roman_khachatryan] , Thank you for your quick reply.

[jira] [Comment Edited] (FLINK-15578) Implement exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17203347#comment-17203347 ] Kenzyme Le edited comment on FLINK-15578 at 9/28/20, 4:36 PM: -- Hi

[jira] [Commented] (FLINK-15578) Implement exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17203347#comment-17203347 ] Kenzyme Le commented on FLINK-15578: Hi [~roman_khachatryan] , In case I am using a DB that doesn't

[jira] [Commented] (FLINK-15578) Implement exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202969#comment-17202969 ] Kenzyme Le commented on FLINK-15578: Great! Thanks for the update. > Implement exactly-once JDBC

[jira] [Commented] (FLINK-15578) Implement exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202371#comment-17202371 ] Kenzyme Le commented on FLINK-15578: Hi [~roman_khachatryan] , I was wondering if there was any

[jira] [Updated] (FLINK-19212) Failed to serialize the result for RPC call : requestTaskManagerInfo.

[ https://issues.apache.org/jira/browse/FLINK-19212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenzyme Le updated FLINK-19212: --- Environment: (was: * Debian 9 * 2 TMs * 2 JMs * 3 ZKs * S3 for checkpoints/savepoints) >

[jira] [Commented] (FLINK-19212) Failed to serialize the result for RPC call : requestTaskManagerInfo.

[ https://issues.apache.org/jira/browse/FLINK-19212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194926#comment-17194926 ] Kenzyme Le commented on FLINK-19212: Here is the related mailing list: