Commits

Commits on Sep 7, 2021

[FLINK-23983][tests] Ensure to close and dispose created keyed-statebackend in StateBackendTestBase
Myasuka
committedSep 7, 2021

Commits on Sep 2, 2021

[FLINK-24106][docs] Remove notice that pyflink does not support state TTL
Myasuka
committedSep 2, 2021

Commits on Aug 31, 2021

[FLINK-23519][metrics] Expose state name as varibale if enable state latency tracking
Myasuka
committedAug 31, 2021

Commits on Aug 27, 2021

[FLINK-23800][rocksdb] Expose live-sst-files-size to RocksDB native metrics
Myasuka
committedAug 27, 2021

Commits on Aug 17, 2021

Commits on Jul 23, 2021

[FLINK-23471][checkpoint] Try best to ensure all operators and state manager handle the checkpoint complete notification
Myasuka
committedJul 23, 2021

Commits on Jul 22, 2021

[FLINK-21411][rocksdb] Update FRocksDB to bump bzip2 dependency version

Myasuka
authored and
tillrohrmann
committedJul 22, 2021

Commits on Jul 16, 2021

[FLINK-23367][state] Ensure InternalPriorityQueue#iterator could be closed for changelog state-backend
Myasuka
committedJul 16, 2021

Commits on Jul 2, 2021

[FLINK-22528][docs] Document latency tracking metrics for state accesses
Myasuka
committedJul 2, 2021

Commits on Jun 21, 2021

[FLINK-23018][state] Enable state factories to handle extended state descriptors
Myasuka
committedJun 21, 2021

Commits on May 31, 2021

[FLINK-22759][docs] Correct the applicability of some RocksDB related options as per operator
Myasuka
committedMay 31, 2021

Commits on Apr 26, 2021

[FLINK-22444][docs] Drop async checkpoint description of state backends in Chinese docs
Myasuka
committedApr 26, 2021

Commits on Apr 20, 2021

[FLINK-21073][docs] Mention that RocksDB would ignore java's equals/hashCode during comparing objects
Myasuka
committedApr 20, 2021

Commits on Apr 12, 2021

[FLINK-22187][docs] Remove description of sync checkpoint mode of HashMapStateBackend

Myasuka
authored and
dawidwys
committedApr 12, 2021

Commits on Apr 1, 2021

[FLINK-16444][state] Enable to create latency tracking state
Myasuka
committedApr 1, 2021
[FLINK-16444][state] Introduce latency tracking state config and basic classes
Myasuka
committedApr 1, 2021
[FLINK-16444][state] Separate state backend and checkpoint options
Myasuka
committedApr 1, 2021

Commits on Mar 26, 2021

Commits on Mar 3, 2021

[hotfix][docs] Fix merge conflicts of checkpointing.md

Myasuka
authored and
sjwiesman
committedMar 3, 2021

Commits on Feb 20, 2021

[FLINK-21213][task] Degrade log level to INFO when ignore to decline checkpoint as task not running
Myasuka
committedFeb 20, 2021

Commits on Jan 29, 2021

[FLINK-21048][docs] Refactor documentation related to switch memory allocator
Myasuka
committedJan 29, 2021

Commits on Jan 28, 2021

Commits on Dec 17, 2020

[FLINK-19013][state-backends] Add start/end logs for state restoration
Myasuka
committedDec 17, 2020

Commits on Nov 30, 2020

[FLINK-20287][docs] Add documentation of how to switch memory allocator in Flink docker image

Myasuka
authored and
carp84
committedNov 30, 2020

Commits on Nov 6, 2020

[FLINK-18004][docs] Update checkpoint UI related pictures in documentation
Myasuka
committedNov 6, 2020

Commits on Oct 14, 2020

[FLINK-18373][state backends][tests] Drop useless RocksDB performance unit tests
Myasuka
committedOct 14, 2020

Commits on Sep 15, 2020

[FLINK-18335] [tests] Add more debuging logs for NotifyCheckpointAbortedITCase (apache#13349 )
Myasuka
committedSep 15, 2020

Commits on Jul 14, 2020

[FLINK-18573][metrics] Add test for loading reporters via service loader

Myasuka
authored and
zentol
committedJul 14, 2020
[FLINK-18573][metrics][influxdb] Fix services directory name

Myasuka
authored and
zentol
committedJul 14, 2020

Commits on Jun 26, 2020

[hot-fix][rocksdb] Ensure RocksDBKeyedStateBackend disposed at RocksDBStateMisuseOptionTest

Myasuka
authored and
carp84
committedJun 26, 2020
[FLINK-17800][rocksdb] Ensure total order seek to avoid user misuse

Myasuka
authored and
carp84
committedJun 26, 2020