[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&focusedCommentId=17290261#comment-17290261 ] Kenzyme Le commented on FLINK-21427: *Would you like to provide a fix for this issue

[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&focusedCommentId=17290241#comment-17290241 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 8:27 PM:

[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&focusedCommentId=17290241#comment-17290241 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 8:21 PM:

[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&focusedCommentId=17290241#comment-17290241 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 8:20 PM:

[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&focusedCommentId=17290241#comment-17290241 ] Kenzyme Le commented on FLINK-21427: *Were you able to verify this (savepoint case)

[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&focusedCommentId=17290198#comment-17290198 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 7:01 PM:

[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&focusedCommentId=17290198#comment-17290198 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 7:00 PM:

[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&focusedCommentId=17290198#comment-17290198 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 6:59 PM:

[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&focusedCommentId=17290198#comment-17290198 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 6:59 PM:

[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&focusedCommentId=17290198#comment-17290198 ] Kenzyme Le commented on FLINK-21427: Hi [~roman_khachatryan] , I was able to succes

[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&focusedCommentId=17289317#comment-17289317 ] Kenzyme Le edited comment on FLINK-21427 at 2/24/21, 5:56 PM:

[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&focusedCommentId=17289317#comment-17289317 ] Kenzyme Le edited comment on FLINK-21427 at 2/23/21, 8:38 PM:

[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&focusedCommentId=17289317#comment-17289317 ] Kenzyme Le commented on FLINK-21427: Hi Roman, *Did you issue stop-with-savepoint c

[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&focusedCommentId=17289266#comment-17289266 ] Kenzyme Le edited comment on FLINK-21427 at 2/23/21, 7:52 PM:

[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&focusedCommentId=17289266#comment-17289266 ] Kenzyme Le edited comment on FLINK-21427 at 2/23/21, 7:19 PM:

[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&focusedCommentId=17289266#comment-17289266 ] Kenzyme Le commented on FLINK-21427: *I'd verify that this checkpoint wasn't already

[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&focusedCommentId=17289147#comment-17289147 ] Kenzyme Le edited comment on FLINK-21427 at 2/23/21, 5:12 PM:

[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&focusedCommentId=17289147#comment-17289147 ] Kenzyme Le edited comment on FLINK-21427 at 2/23/21, 4:49 PM:

[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&focusedCommentId=17289147#comment-17289147 ] Kenzyme Le commented on FLINK-21427: My other hunch about this is that my Pojos did

[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&focusedCommentId=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&focusedCommentId=17288801#comment-17288801 ] Kenzyme Le commented on FLINK-21427: Hello [~roman_khachatryan], Any idea on possi

[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&focusedCommentId=17288795#comment-17288795 ] Kenzyme Le commented on FLINK-21427: I'm wondering if [state.checkpoints.num-retain

[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 doe

[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 com

[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 ca

[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 ca

[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 Af

[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 [ FlinkKafkaInternalProducer|https://github.com/apache/flink/blob/m

[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 [ FlinkKafkaInternalProducer|https://github.com/apache/flink/blob/m

[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 Issu

[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 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&focusedCommentId=17209035#comment-17209035 ] Kenzyme Le commented on FLINK-15578: Thank you for the update [~roman_khachatryan] .

[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&focusedCommentId=17204063#comment-17204063 ] Kenzyme Le commented on FLINK-15578: Hello [~roman_khachatryan] , Thank you for you

[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&focusedCommentId=17203347#comment-17203347 ] Kenzyme Le edited comment on FLINK-15578 at 9/28/20, 4:36 PM:

[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&focusedCommentId=17203347#comment-17203347 ] Kenzyme Le commented on FLINK-15578: Hi [~roman_khachatryan] , In case I am using a

[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&focusedCommentId=17202969#comment-17202969 ] Kenzyme Le commented on FLINK-15578: Great! Thanks for the update. > Implement exac

[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&focusedCommentId=17202371#comment-17202371 ] Kenzyme Le commented on FLINK-15578: Hi [~roman_khachatryan] , I was wondering if t

[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) > Fa

[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&focusedCommentId=17194926#comment-17194926 ] Kenzyme Le commented on FLINK-19212: Here is the related mailing list: [http://mail