flink-connector-aws icon indicating copy to clipboard operation
flink-connector-aws copied to clipboard
verified publisher icon apache

[FLINK-37908] Resolve EFO-enabled KinesisStreamsSource initialization failure on automated restarts

Open digitalpoetry opened this issue 9 months ago • 4 comments

Purpose of the change

Resolve race condition on automated restarts of Flink apps with an EFO-enabled KinesisStreamsSource.

Verifying this change

This change is a trivial rework / code cleanup without any test coverage.

This change is aligned with a previously implemented fix for the same issue observed within the FlinkKinesisConsumer connector:

  • https://issues.apache.org/jira/browse/FLINK-24431
  • https://github.com/apache/flink/pull/17417

Significant changes

(Please check any boxes [x] if the answer is "yes". You can first publish the PR and check them afterwards, for convenience.)

  • [ ] Dependencies have been added or upgraded
  • [ ] Public API has been changed (Public API is any class annotated with @Public(Evolving))
  • [ ] Serializers have been changed
  • [ ] New feature has been introduced
    • If yes, how is this documented? (not applicable / docs / JavaDocs / not documented)

digitalpoetry avatar Jun 06 '25 01:06 digitalpoetry

Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)

boring-cyborg[bot] avatar Jun 06 '25 01:06 boring-cyborg[bot]

@digitalpoetry you have format violations in CI checks .

davidradl avatar Jun 17 '25 08:06 davidradl

For some reason, I was able to build on my work machine, but not my personal machine 🤷 I'll need to look into that... Fixed now, thank you @davidradl

digitalpoetry avatar Jun 17 '25 10:06 digitalpoetry

Can I get another run of the CI pipeline, please? I think the failures were fixed recently in https://github.com/apache/flink-connector-aws/pull/216

digitalpoetry avatar Jul 13 '25 05:07 digitalpoetry