Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25610

[FLIP-171] Kinesis Firehose implementation of Async Sink Table API

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    Description

      Motivation

      User stories:
      As a Flink user, I’d like to use the Table API for the new Kinesis Firehose async sink.

      Scope:

      • Add a new module for flink-connector-kinesis-data-firehose-table.
      • Implement a new KinesisFirehoseDynamicTableSink that uses KinesisDataFirehoseSink Async Implementation and implements AsyncDynamicTableSink.
      • The implementation introduces Async Sink configurations as optional options in the table definition, with default values derived from the KinesisDataFirehose default values.
      • Unit/Integration testing. modify KinesisTableAPI tests for the new implementation, add unit tests for AsyncDynamicTableSink and KinesisDynamicTableSink and KinesisDynamicTableSinkFactory.
      • Java / code-level docs.
      • Add documentations for Table Api connector for Kinesis data firehose.

      References

      More details to be found https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            chalixar Ahmed Hamdy
            chalixar Ahmed Hamdy
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment