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

Programmatically select timer storage backend

    XMLWordPrintableJSON

Details

    Description

      FLINK-9486 introduced timer storage on the RocksDB storage backend.  Right now it is only possible to configure RocksDB as the storage for timers by settings the state.backend.rocksdb.timer-service.factory value in the configuration file for Flink.

      As the state storage backend can be programmatically selected by by jobs via  env.setStateBackend(...), the timer backend should also be configurable programmatically.

      Different jobs should be able to store their timers in different storage backends.

      Attachments

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: