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

Wrong javadoc and documentation for buffer timeout

    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

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: