|
|
|
FLINK-36598
|
FLINK-34975
[state/forst] Refactor initialization of ForSt db core
|
Zakelly Lan
|
Zakelly Lan
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-36592
|
FLINK-34975
Support file cache for ForStStateBackend
|
Yanfei Lei
|
Yanfei Lei
|
|
Resolved |
Resolved
|
|
|
|
|
|
|
|
FLINK-36526
|
FLINK-34975
Optimize the overhead of writing with direct buffer in ForSt
|
Zakelly Lan
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-36395
|
FLINK-34975
Graceful quit for Forst StateBackend
|
Zakelly Lan
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-36374
|
FLINK-34975
Bundle forst statebackend in flink-dist and provide shortcut to enable
|
Zakelly Lan
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-36373
|
FLINK-34975
Support dispatch state requests in task thread
|
Yanfei Lei
|
Yanfei Lei
|
|
Resolved |
Resolved
|
|
|
|
|
|
|
|
FLINK-36364
|
FLINK-34975
Do not reuse serialized key in Forst map state and/or other namespaces
|
Zakelly Lan
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-36331
|
FLINK-34975
Support multiGet for forstdb
|
Yanfei Lei
|
Yanfei Lei
|
|
Resolved |
Resolved
|
|
|
|
|
|
|
|
FLINK-36321
|
FLINK-34975
Execute read/write state request in different executor
|
Yanfei Lei
|
Yanfei Lei
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-36314
|
FLINK-34975
Support state V1 interface
|
Yanfei Lei
|
Yanfei Lei
|
|
Resolved |
Resolved
|
|
|
|
|
|
|
|
FLINK-36243
|
FLINK-34975
Store namespace in ContextKey and state request
|
Yanfei Lei
|
Yanfei Lei
|
|
Resolved |
Resolved
|
|
|
|
|
|
|
|
FLINK-35928
|
FLINK-34975
ForSt supports compiling with RocksDB
|
Yanfei Lei
|
Hangxiang Yu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-35927
|
FLINK-34975
Make ForStFlinkFileSystem save misc file in local filesystem
|
Hangxiang Yu
|
Hangxiang Yu
|
|
Resolved |
Resolved
|
|
|
|
|
|
|
|
FLINK-35667
|
FLINK-34975
Implement Reducing Async State API for ForStStateBackend
|
Yanfei Lei
|
Zakelly Lan
|
|
Resolved |
Resolved
|
|
|
|
|
|
|
|
FLINK-35666
|
FLINK-34975
Implement Aggregating Async State API for ForStStateBackend
|
Jie Pu
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35495
|
FLINK-34975
The native metrics for column family are not reported
|
Unassigned
|
Yanfei Lei
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-35410
|
FLINK-34975
Avoid sync waiting in coordinator thread of ForSt executor
|
Zakelly Lan
|
Zakelly Lan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35389
|
FLINK-34975
Implement List Async State API for ForStStateBackend
|
Zakelly Lan
|
Hangxiang Yu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35125
|
FLINK-34975
Implement ValueState for ForStStateBackend
|
Jinzhong Li
|
Jinzhong Li
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35049
|
FLINK-34975
Implement Map Async State API for ForStStateBackend
|
Yanfei Lei
|
Hangxiang Yu
|
|
Resolved |
Done
|
|
|
|
|
|
|
|
FLINK-35048
|
FLINK-34975
Implement all methods of AsyncKeyedStateBakend
|
Hangxiang Yu
|
Hangxiang Yu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35047
|
FLINK-34975
Introduce ForStStateBackend to manage ForSt
|
Hangxiang Yu
|
Hangxiang Yu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35045
|
FLINK-34975
Introduce ForStFileSystem to support reading and writing with ByteBuffer
|
Hangxiang Yu
|
Hangxiang Yu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35044
|
FLINK-34975
Introduce statebackend-forst module
|
Hangxiang Yu
|
Hangxiang Yu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-35043
|
FLINK-34975
Release beta version of ForSt
|
Hangxiang Yu
|
Hangxiang Yu
|
|
Resolved |
Fixed
|
|
|
|
|