[jira] [Comment Edited] (FLINK-26657) Resilient Kinesis consumption

[ https://issues.apache.org/jira/browse/FLINK-26657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507781#comment-17507781 ] John Karp edited comment on FLINK-26657 at 3/16/22, 6:03 PM: -

[jira] [Commented] (FLINK-26657) Resilient Kinesis consumption

[ https://issues.apache.org/jira/browse/FLINK-26657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17507781#comment-17507781 ] John Karp commented on FLINK-26657: --- I was considering contributing a fix, though befo

[jira] [Updated] (FLINK-26657) Resilient Kinesis consumption

[ https://issues.apache.org/jira/browse/FLINK-26657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Karp updated FLINK-26657: -- Description: Currently, any sort of error reading from a Kinesis stream will quickly result in a job-

[jira] [Created] (FLINK-26657) Resilient Kinesis consumption

John Karp created FLINK-26657: - Summary: Resilient Kinesis consumption Key: FLINK-26657 URL: https://issues.apache.org/jira/browse/FLINK-26657 Project: Flink Issue Type: Improvement Com

[jira] [Comment Edited] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

[ https://issues.apache.org/jira/browse/FLINK-24639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435481#comment-17435481 ] John Karp edited comment on FLINK-24639 at 10/28/21, 3:09 PM:

[jira] [Commented] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

[ https://issues.apache.org/jira/browse/FLINK-24639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435481#comment-17435481 ] John Karp commented on FLINK-24639: --- Actually, I don't think the multi-region handling

[jira] [Commented] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

[ https://issues.apache.org/jira/browse/FLINK-24639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435098#comment-17435098 ] John Karp commented on FLINK-24639: --- Thanks [~dannycranmer], I opened https://github.c

[jira] [Commented] (FLINK-24580) Kinesis connect time out error is not handled as recoverable

[ https://issues.apache.org/jira/browse/FLINK-24580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434604#comment-17434604 ] John Karp commented on FLINK-24580: --- I've tested out this patch, it seems to work in m

[jira] [Created] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

John Karp created FLINK-24639: - Summary: Improve assignment of Kinesis shards to subtasks Key: FLINK-24639 URL: https://issues.apache.org/jira/browse/FLINK-24639 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-24580) Kinesis connect time out error is not handled as recoverable

John Karp created FLINK-24580: - Summary: Kinesis connect time out error is not handled as recoverable Key: FLINK-24580 URL: https://issues.apache.org/jira/browse/FLINK-24580 Project: Flink Issue