Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25318 Improvement of scheduler and execution for Flink OLAP
  3. FLINK-33054

Align the job execution result fetching timeout in CollectResultFetcher with akka timeout

    XMLWordPrintableJSON

Details

    Description

      Currently in CollectResultFetcher, the job execution result will be fetched after job's termination. In FLINK-17735, we arbitrarily introduce a static timeout for this rpc call. However, in OLAP scenario, the Dispatcher endpoint might be too busy to reply in time. We'd like to set it according to the akka ask timeout, which is commonly used as rpc timeout in Flink.

      Attachments

        Issue Links

          Activity

            People

              guoyangze Yangze Guo
              guoyangze Yangze Guo
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: