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

Make Queue Capacity and Timeout of AsyncWaitOperator changeable during runtime

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Reopened
    • Not a Priority
    • Resolution: Unresolved
    • None
    • None
    • API / DataStream
    • None

    Description

      A user that I have recently been working with has the requirement to change the capacity and possibly the timeout during the runtime of a job.

      Conceptually, this should be possibly by just passing these parameters to the RichAsyncFunction via its RuntimeContext. The change of the timeout would only apply to future records and the change in the queue capacity would take effect immediately.

      Attachments

        Activity

          People

            Unassigned Unassigned
            knaufk Konstantin Knauf
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

            Dates

              Created:
              Updated: