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

query_configuration.html content out date

    XMLWordPrintableJSON

Details

    Description

      https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/streaming/query_configuration.html

      code samples is out date.

       

      tConfig.setIdleStateRetentionTime(Time.hours(12), Time.hours(24))

      {{}}

      Specifies a minimum and a maximum time interval for how long idle state, i.e., state which was not updated, will be retained. State will never be cleared until it was idle for less than the minimum time and will never be kept if it was idle for more than the maximum time.
      When new data arrives for previously cleaned-up state, the new data will be handled as if it was the first data. This can result in previous results being overwritten.
      Set to 0 (zero) to never clean-up the state.
      NOTE: Cleaning up state requires additional bookkeeping which becomes less expensive for larger differences of minTime and maxTime. The difference between minTime and maxTime must be at least 5 minutes.
      NOTE: Currently maxTime will be ignored and it will automatically derived from minTime as 1.5 x minTime.

      Deprecated
      use setIdleStateRetention(Duration) instead.
      Params:
      minTime – The minimum time interval for which idle state is retained. Set to 0 (zero) to never clean-up the state.
      maxTime – The maximum time interval for which idle state is retained. Must be at least 5 minutes greater than minTime. Set to 0 (zero) to never clean-up the state

      {{}}

      Attachments

        Activity

          People

            Unassigned Unassigned
            hiscat 谢波
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: