Commits

History for

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 21, 2021

[hotfix][state backend] Put the delegating log to ChangelogStateBackend constructor

curcur
authored and
rkhachatryan
committedMar 21, 2021

Commits on Mar 20, 2021

[FLINK-21831][state][changelog] Add missing delegation of KeyGroupedInternalPriorityQueue
pnowojski
committedMar 20, 2021

Commits on Mar 15, 2021

[FLINK-21354] Introduce ChangelogStateBackend to delegate state access

curcur
authored and
rkhachatryan
committedMar 15, 2021

Commits on Mar 4, 2021

[FLINK-20496][state backends] RocksDB partitioned index/filters option.

liuyufei
authored and
carp84
committedMar 4, 2021
[FLINK-20496][state backends] Introduce RocksDB metadata block size setting.

liuyufei
authored and
carp84
committedMar 4, 2021

Commits on Mar 1, 2021

[FLINK-21505] Enforce common/unified savepoint format at the operator level

aljoscha
authored and
dawidwys
committedMar 1, 2021
[FLINK-21505] Extract SnapshotExecutionType from SnapshotStrategyRunner

aljoscha
authored and
dawidwys
committedMar 1, 2021
[FLINK-21505] Factor snapshot resource creation out of RocksFullSnapshotStrategy

aljoscha
authored and
dawidwys
committedMar 1, 2021
[hotfix][state] Remove hardcoded backend class name check
rkhachatryan
committedMar 1, 2021

Commits on Feb 25, 2021

[FLINK-19467][runtime / state backends] Implement HashMapStateBackend and EmbeddedRocksDBStateBackend
sjwiesman
committedFeb 25, 2021

Commits on Feb 24, 2021

[FLINK-21453][checkpointing][refactor] Replace advanceToEndOfTime with new CheckpointType.SAVEPOINT_TERMINATE
pnowojski
committedFeb 24, 2021
[hotfix] Fix possible null pointer exception in RocksStatesPerKeyGroupMergeIterator
dawidwys
committedFeb 24, 2021
[FLINK-21344] Do not store heap timers in raw operator state for a
dawidwys
committedFeb 24, 2021
[FLINK-21344] Handle heap timers in Rocks state
dawidwys
committedFeb 24, 2021
[hotfix] Fix RocksIncrementalCheckpointRescalingTest
dawidwys
committedFeb 24, 2021
[refactor] Extract common interface for a single Rocks state
dawidwys
committedFeb 24, 2021
[refactor] Remove AbstractRocksDBRestoreOperation
dawidwys
committedFeb 24, 2021
[hotfix] Cleanup raw types around PriorityQueueSetFactory
dawidwys
committedFeb 24, 2021
[hotfix] Remove unnecessary if in RocksIncrementalSnapshotStrategy
dawidwys
committedFeb 24, 2021

Commits on Feb 22, 2021

Revert FLINK-21417 due to performance regression.
xintongsong
committedFeb 22, 2021

Commits on Feb 21, 2021

[FLINK-21417][core] Update MemorySegmentFactory with explicit segment types.
xintongsong
committedFeb 21, 2021

Commits on Feb 5, 2021

Commits on Jan 29, 2021