[jira] [Created] (FLINK-35897) Some checkpoint files and localState files can't be cleanUp when checkpoint is aborted

Jinzhong Li created FLINK-35897: --- Summary: Some checkpoint files and localState files can't be cleanUp when checkpoint is aborted Key: FLINK-35897 URL: https://issues.apache.org/jira/browse/FLINK-35897

[jira] [Created] (FLINK-35163) Utilize ForSt's native MultiGet API to optimize remote state access

Jinzhong Li created FLINK-35163: --- Summary: Utilize ForSt's native MultiGet API to optimize remote state access Key: FLINK-35163 URL: https://issues.apache.org/jira/browse/FLINK-35163 Project: Flink

[jira] [Created] (FLINK-35162) Support grouping state get and put access

Jinzhong Li created FLINK-35162: --- Summary: Support grouping state get and put access Key: FLINK-35162 URL: https://issues.apache.org/jira/browse/FLINK-35162 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35161) Implement StateExecutor for ForStStateBackend

Jinzhong Li created FLINK-35161: --- Summary: Implement StateExecutor for ForStStateBackend Key: FLINK-35161 URL: https://issues.apache.org/jira/browse/FLINK-35161 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-35125) Implement ValueState for ForStStateBackend

Jinzhong Li created FLINK-35125: --- Summary: Implement ValueState for ForStStateBackend Key: FLINK-35125 URL: https://issues.apache.org/jira/browse/FLINK-35125 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window

Jinzhong Li created FLINK-35069: --- Summary: ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window Key: FLINK-35069 URL: https://issues.apache.org/jira/browse/FLINK-35069

[jira] [Created] (FLINK-34982) FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State

Jinzhong Li created FLINK-34982: --- Summary: FLIP-428: Fault Tolerance/Rescale Integration for Disaggregated State Key: FLINK-34982 URL: https://issues.apache.org/jira/browse/FLINK-34982 Project: Flink

[jira] [Created] (FLINK-34981) FLIP-426: Grouping Remote State Access

Jinzhong Li created FLINK-34981: --- Summary: FLIP-426: Grouping Remote State Access Key: FLINK-34981 URL: https://issues.apache.org/jira/browse/FLINK-34981 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-34936) Register shared state files to FileMergingSnapshotManager

Jinzhong Li created FLINK-34936: --- Summary: Register shared state files to FileMergingSnapshotManager Key: FLINK-34936 URL: https://issues.apache.org/jira/browse/FLINK-34936 Project: Flink Issue

[jira] [Created] (FLINK-34670) Use SynchronousQueue to create asyncOperationsThreadPool for SubtaskCheckpointCoordinatorImpl

Jinzhong Li created FLINK-34670: --- Summary: Use SynchronousQueue to create asyncOperationsThreadPool for SubtaskCheckpointCoordinatorImpl Key: FLINK-34670 URL: https://issues.apache.org/jira/browse/FLINK-34670

[jira] [Created] (FLINK-34078) Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package

Jinzhong Li created FLINK-34078: --- Summary: Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package Key: FLINK-34078 URL: https://issues.apache.org/jira/browse/FLINK-34078

[jira] [Created] (FLINK-34050) Rocksdb state has space amplification after rescaling with DeleteRange

Jinzhong Li created FLINK-34050: --- Summary: Rocksdb state has space amplification after rescaling with DeleteRange Key: FLINK-34050 URL: https://issues.apache.org/jira/browse/FLINK-34050 Project: Flink

[jira] [Created] (FLINK-33881) [TtlListState]Avoid copy and update value when TtlListState don‘t have expired element

Jinzhong Li created FLINK-33881: --- Summary: [TtlListState]Avoid copy and update value when TtlListState don‘t have expired element Key: FLINK-33881 URL: https://issues.apache.org/jira/browse/FLINK-33881

[jira] [Created] (FLINK-32955) Support state compatibility between enabling TTL and disabling TTL

Jinzhong Li created FLINK-32955: --- Summary: Support state compatibility between enabling TTL and disabling TTL Key: FLINK-32955 URL: https://issues.apache.org/jira/browse/FLINK-32955 Project: Flink

[jira] [Created] (FLINK-32953) [State TTL]resolve data correctness problem after ttl was changed

Jinzhong Li created FLINK-32953: --- Summary: [State TTL]resolve data correctness problem after ttl was changed Key: FLINK-32953 URL: https://issues.apache.org/jira/browse/FLINK-32953 Project: Flink

[jira] [Created] (FLINK-28515) The files in local recovery directory hasn't be clean up properly after checkpoint abort

Jinzhong Li created FLINK-28515: --- Summary: The files in local recovery directory hasn't be clean up properly after checkpoint abort Key: FLINK-28515 URL: https://issues.apache.org/jira/browse/FLINK-28515

[jira] [Created] (FLINK-25314) Update log4j2 version to 2.16.0

Jinzhong Li created FLINK-25314: --- Summary: Update log4j2 version to 2.16.0 Key: FLINK-25314 URL: https://issues.apache.org/jira/browse/FLINK-25314 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-25094) The verify code in LatencyTrackingMapStateTest#verifyIterator is not actually executed

Jinzhong Li created FLINK-25094: --- Summary: The verify code in LatencyTrackingMapStateTest#verifyIterator is not actually executed Key: FLINK-25094 URL: https://issues.apache.org/jira/browse/FLINK-25094