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

There is no API to configure the timer state backend

    XMLWordPrintableJSON

Details

    Description

      Flink 1.6.0, via FLINK-9485, introduced the option to store timers in RocksDB instead of the heap.  Alas, this can only be configured via the state.backend.rocksdb.timer-service.factory config file option.  That means that the choice of state backend to use for timer can't be made on a per job basis on a shared cluster.

      There is a need for an API in RocksDBStateBackend to configure the backend per job.

      Attachments

        Issue Links

          is fixed by

          Bug - A problem which impairs or prevents the functions of the product. FLINK-11193 Rocksdb timer service factory configuration option is not settable per job

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Closed

          Activity

            People

              Unassigned Unassigned
              elevy Elias Levy
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: