Site LogoSite Logo
  • 🗃️ read_me
  • ai
  • backend
    • api
    • caching
    • canal
    • concepts
    • data-systems
    • databases
    • frameworks
    • hologres
    • integration
    • jvm
    • languages
    • libraries
    • media
    • os
    • sql
    • streaming
      • apache_spark
      • delivery_semantics_at_most_at_least_exactly
      • exactly_once_semantics
      • flink
        • flink_
        • flink_architecture
        • flink_checkpointing
        • flink_keyed_state
        • flink_keyed_streams
        • flink_notions_of_time
        • flink_operator_state
        • flink_process_functions
        • flink_savepoints
        • flink_side_outputs
        • flink_state
        • flink_watermarks
        • flink_window_assigners
        • flink_window_functions
        • flink_windows
      • kafka_architecture
      • kafka_cli_cheatsheet
      • kafka_partition_ordering_keying
      • sink
      • stream_processing_semantics
    • system-design
    • transport
  • concepts
  • dump
  • finance
  • frontend
  • home
  • infrastructure
  • readings
  • skating
  • backend
  • streaming
  • flink
  • flink_state

🗓️ 20012025 1436

FLINK STATE

Features​

Why is flink involved in managing state

  • Local:
    • Flink state is kept local to the machine that processes it
    • Can be accessed at memory speed
  • Durable: Flink state is fault-tolerant
    • Automatically checkpointed at regular intervals
    • Restored upon failure
  • Vertically scalable
    • Flink state can be kept in embedded RocksDB instances
    • Scale by adding more local disk
  • Horizontally scalable
    • Flink state is redistributed as your cluster grows and shrinks

Types​

  • flink_operator_state
  • flink_keyed_state

References​

  • https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/learn-flink/etl/
Previous
flink_side_outputs
Next
flink_watermarks
  • Features
  • Types
  • References