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

Wrong javadoc and documentation for buffer timeout

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

Details

    • Hide
      Configuring buffer timeout to be equal to `-1` to flush only when buffers were full was broken in FLINK-18832. In Stream execution mode it was overwritten with 100ms. Fortunately it should not have had a visible impact as `100ms` should still be enough time to fill in buffers before sending them downstream.
      Show
      Configuring buffer timeout to be equal to `-1` to flush only when buffers were full was broken in FLINK-18832 . In Stream execution mode it was overwritten with 100ms. Fortunately it should not have had a visible impact as `100ms` should still be enough time to fill in buffers before sending them downstream.

    Description

      The javadoc for setBufferTimeout and similarly the documentation for execution.buffer-timeout claims:

          /**
           * Sets the maximum time frequency (milliseconds) for the flushing of the output buffers. By
           * default the output buffers flush frequently to provide low latency and to aid smooth
           * developer experience. Setting the parameter can result in three logical modes:
           *
           * <ul>
           *   <li>A positive integer triggers flushing periodically by that integer
           *   <li>0 triggers flushing after every record thus minimizing latency
           *   <li>-1 triggers flushing only when the output buffer is full thus maximizing throughput
           * </ul>
           *
           * @param timeoutMillis The maximum time between two output flushes.
           */
      

      which is not true.

      The -1 value translates to 100ms. See org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator#checkAndResetBufferTimeout

      Attachments

        Activity

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

          People

            dwysakowicz Dawid Wysakowicz
            dwysakowicz Dawid Wysakowicz
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment