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

FLIP-309: Support using larger checkpointing interval when source is processing backlog

    XMLWordPrintableJSON

Details

    • ProcessingBacklog is introduced to demonstrate whether a record should be processed with low latency or high throughput. ProcessingBacklog can be set by source operators, and can be used to change the checkpoint internal of a job during runtime.

    Attachments

      Issue Links

        causes

        Bug - A problem which impairs or prevents the functions of the product. FLINK-34149 Flink Kafka connector can't compile against 1.19-SNAPSHOT

        • Blocker - Blocks development and/or testing work, production could not run
        • Closed
        relates to

        New Feature - A new feature of the product, which has yet to be developed. FLINK-18578 Add rejecting checkpoint logic in source

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Open

        New Feature - A new feature of the product, which has yet to be developed. FLINK-22805 Dynamic configuration of Flink checkpoint interval

        • Minor - Minor loss of function, or other problem where easy workaround is present.
        • Open
        links to

        Web Link GitHub Pull Request #22931

        Activity

          People

            yunfengzhou Yunfeng Zhou
            yunfengzhou Yunfeng Zhou
            Votes:
            0 Vote for this issue
            Watchers:
            9 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: