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

Allow for customization of emitRecordAndUpdateState in Kinesis connector

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • None
    • 1.5.0
    • Connectors / Kinesis
    • None

    Description

      It should be possible to override the method to intercept the emit behavior, in this case for the purpose of custom watermark support.

       

      Attachments

        Issue Links

          is related to

          New Feature - A new feature of the product, which has yet to be developed. FLINK-5697 Add per-shard watermarks for FlinkKinesisConsumer

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #5480

          Activity

            People

              thw Thomas Weise
              thw Thomas Weise
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: