[jira] [Created] (FLINK-37158) Introduce ForSt to existing ITCases

Yanfei Lei created FLINK-37158: -- Summary: Introduce ForSt to existing ITCases Key: FLINK-37158 URL: https://issues.apache.org/jira/browse/FLINK-37158 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37140) Create InternalTimerServiceAsyncImpl when restore async operator

Yanfei Lei created FLINK-37140: -- Summary: Create InternalTimerServiceAsyncImpl when restore async operator Key: FLINK-37140 URL: https://issues.apache.org/jira/browse/FLINK-37140 Project: Flink

[jira] [Created] (FLINK-37021) Implement fast rescaling for ForStKeyedStateBackend

Yanfei Lei created FLINK-37021: -- Summary: Implement fast rescaling for ForStKeyedStateBackend Key: FLINK-37021 URL: https://issues.apache.org/jira/browse/FLINK-37021 Project: Flink Issue Type: S

[jira] [Created] (FLINK-36961) Wait ForSt state excutor shutdown when disposing

Yanfei Lei created FLINK-36961: -- Summary: Wait ForSt state excutor shutdown when disposing Key: FLINK-36961 URL: https://issues.apache.org/jira/browse/FLINK-36961 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-36957) Implement async StreamFlatMap

Yanfei Lei created FLINK-36957: -- Summary: Implement async StreamFlatMap Key: FLINK-36957 URL: https://issues.apache.org/jira/browse/FLINK-36957 Project: Flink Issue Type: Sub-task Re

[jira] [Created] (FLINK-36935) Implement fast link for ForStFileSystem

Yanfei Lei created FLINK-36935: -- Summary: Implement fast link for ForStFileSystem Key: FLINK-36935 URL: https://issues.apache.org/jira/browse/FLINK-36935 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36899) Introduce metrics for cache

Yanfei Lei created FLINK-36899: -- Summary: Introduce metrics for cache Key: FLINK-36899 URL: https://issues.apache.org/jira/browse/FLINK-36899 Project: Flink Issue Type: Sub-task Repo

[jira] [Created] (FLINK-36875) Complete timer before emiting watermark

Yanfei Lei created FLINK-36875: -- Summary: Complete timer before emiting watermark Key: FLINK-36875 URL: https://issues.apache.org/jira/browse/FLINK-36875 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36853) Support getOrCreateKeyedState for AsyncKeyedStateBackend

Yanfei Lei created FLINK-36853: -- Summary: Support getOrCreateKeyedState for AsyncKeyedStateBackend Key: FLINK-36853 URL: https://issues.apache.org/jira/browse/FLINK-36853 Project: Flink Issue Ty

[jira] [Created] (FLINK-36819) [state/forst] Support link() in ForStFlinkFileSystem

Yanfei Lei created FLINK-36819: -- Summary: [state/forst] Support link() in ForStFlinkFileSystem Key: FLINK-36819 URL: https://issues.apache.org/jira/browse/FLINK-36819 Project: Flink Issue Type:

[jira] [Created] (FLINK-36749) Implement rescaling for ForStKeyedStateBackend

Yanfei Lei created FLINK-36749: -- Summary: Implement rescaling for ForStKeyedStateBackend Key: FLINK-36749 URL: https://issues.apache.org/jira/browse/FLINK-36749 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-36693) Implement checkpoint for ForStSyncKeyedStateBackend

Yanfei Lei created FLINK-36693: -- Summary: Implement checkpoint for ForStSyncKeyedStateBackend Key: FLINK-36693 URL: https://issues.apache.org/jira/browse/FLINK-36693 Project: Flink Issue Type: S

[jira] [Created] (FLINK-36592) Support file cache for ForStStateBackend

Yanfei Lei created FLINK-36592: -- Summary: Support file cache for ForStStateBackend Key: FLINK-36592 URL: https://issues.apache.org/jira/browse/FLINK-36592 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36373) Support distribute state requests in task thread

Yanfei Lei created FLINK-36373: -- Summary: Support distribute state requests in task thread Key: FLINK-36373 URL: https://issues.apache.org/jira/browse/FLINK-36373 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-36331) Support multiGet when DB all in local

Yanfei Lei created FLINK-36331: -- Summary: Support multiGet when DB all in local Key: FLINK-36331 URL: https://issues.apache.org/jira/browse/FLINK-36331 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36321) Execute read/write state request in different executor

Yanfei Lei created FLINK-36321: -- Summary: Execute read/write state request in different executor Key: FLINK-36321 URL: https://issues.apache.org/jira/browse/FLINK-36321 Project: Flink Issue Type

[jira] [Created] (FLINK-36314) Support state V1 interface

Yanfei Lei created FLINK-36314: -- Summary: Support state V1 interface Key: FLINK-36314 URL: https://issues.apache.org/jira/browse/FLINK-36314 Project: Flink Issue Type: Sub-task Repor

[jira] [Created] (FLINK-36243) Store namespace in ContextKey

Yanfei Lei created FLINK-36243: -- Summary: Store namespace in ContextKey Key: FLINK-36243 URL: https://issues.apache.org/jira/browse/FLINK-36243 Project: Flink Issue Type: Sub-task Comp

[jira] [Created] (FLINK-35495) The native metrics for column family are not reported

Yanfei Lei created FLINK-35495: -- Summary: The native metrics for column family are not reported Key: FLINK-35495 URL: https://issues.apache.org/jira/browse/FLINK-35495 Project: Flink Issue Type:

[jira] [Created] (FLINK-35405) Add buffer size/in-flight records metrics for AsyncExecutionController

Yanfei Lei created FLINK-35405: -- Summary: Add buffer size/in-flight records metrics for AsyncExecutionController Key: FLINK-35405 URL: https://issues.apache.org/jira/browse/FLINK-35405 Project: Flink

[jira] [Created] (FLINK-35158) Error handling in StateFuture's callback

Yanfei Lei created FLINK-35158: -- Summary: Error handling in StateFuture's callback Key: FLINK-35158 URL: https://issues.apache.org/jira/browse/FLINK-35158 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35031) Event timer firing under async execution model

Yanfei Lei created FLINK-35031: -- Summary: Event timer firing under async execution model Key: FLINK-35031 URL: https://issues.apache.org/jira/browse/FLINK-35031 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-35030) Introduce Epoch Manager for watermark under async execution

Yanfei Lei created FLINK-35030: -- Summary: Introduce Epoch Manager for watermark under async execution Key: FLINK-35030 URL: https://issues.apache.org/jira/browse/FLINK-35030 Project: Flink Issu

[jira] [Created] (FLINK-35029) Store timer in JVM heap when async execution enabled

Yanfei Lei created FLINK-35029: -- Summary: Store timer in JVM heap when async execution enabled Key: FLINK-35029 URL: https://issues.apache.org/jira/browse/FLINK-35029 Project: Flink Issue Type:

[jira] [Created] (FLINK-35028) Processing timer firing under async execution model

Yanfei Lei created FLINK-35028: -- Summary: Processing timer firing under async execution model Key: FLINK-35028 URL: https://issues.apache.org/jira/browse/FLINK-35028 Project: Flink Issue Type: S

[jira] [Created] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController

Yanfei Lei created FLINK-35027: -- Summary: Implement checkpoint drain in AsyncExecutionController Key: FLINK-35027 URL: https://issues.apache.org/jira/browse/FLINK-35027 Project: Flink Issue Type

[jira] [Created] (FLINK-35026) Introduce async-state configurations

Yanfei Lei created FLINK-35026: -- Summary: Introduce async-state configurations Key: FLINK-35026 URL: https://issues.apache.org/jira/browse/FLINK-35026 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator

Yanfei Lei created FLINK-35025: -- Summary: Wire AsyncExecutionController to AbstractStreamOperator Key: FLINK-35025 URL: https://issues.apache.org/jira/browse/FLINK-35025 Project: Flink Issue Typ

[jira] [Created] (FLINK-35024) Implement record order preservation and buffering of AsyncExecutionController

Yanfei Lei created FLINK-35024: -- Summary: Implement record order preservation and buffering of AsyncExecutionController Key: FLINK-35024 URL: https://issues.apache.org/jira/browse/FLINK-35024 Project: Fl

[jira] [Created] (FLINK-34667) Changelog state backend support local rescaling

Yanfei Lei created FLINK-34667: -- Summary: Changelog state backend support local rescaling Key: FLINK-34667 URL: https://issues.apache.org/jira/browse/FLINK-34667 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34624) Enable local recovery in ChangelogRescalingITCase

Yanfei Lei created FLINK-34624: -- Summary: Enable local recovery in ChangelogRescalingITCase Key: FLINK-34624 URL: https://issues.apache.org/jira/browse/FLINK-34624 Project: Flink Issue Type: Tec

[jira] [Created] (FLINK-32677) flink-benchmarks-regression-check failed to send slack messages since 2023.07.17

Yanfei Lei created FLINK-32677: -- Summary: flink-benchmarks-regression-check failed to send slack messages since 2023.07.17 Key: FLINK-32677 URL: https://issues.apache.org/jira/browse/FLINK-32677 Project:

[jira] [Created] (FLINK-32443) Translate "State Processor API" page into Chinese

Yanfei Lei created FLINK-32443: -- Summary: Translate "State Processor API" page into Chinese Key: FLINK-32443 URL: https://issues.apache.org/jira/browse/FLINK-32443 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-32440) Introduce file merging configuration

Yanfei Lei created FLINK-32440: -- Summary: Introduce file merging configuration Key: FLINK-32440 URL: https://issues.apache.org/jira/browse/FLINK-32440 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32018) Many builds of benchmark have been interrupted since 20230428

Yanfei Lei created FLINK-32018: -- Summary: Many builds of benchmark have been interrupted since 20230428 Key: FLINK-32018 URL: https://issues.apache.org/jira/browse/FLINK-32018 Project: Flink Is

[jira] [Created] (FLINK-31969) Remove all local recovery files immediately when local recovery fail

Yanfei Lei created FLINK-31969: -- Summary: Remove all local recovery files immediately when local recovery fail Key: FLINK-31969 URL: https://issues.apache.org/jira/browse/FLINK-31969 Project: Flink

[jira] [Created] (FLINK-31876) [JUnit5 Migration] Module: flink-queryable-state

Yanfei Lei created FLINK-31876: -- Summary: [JUnit5 Migration] Module: flink-queryable-state Key: FLINK-31876 URL: https://issues.apache.org/jira/browse/FLINK-31876 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-30890) Backup codespeed‘s data regularly

Yanfei Lei created FLINK-30890: -- Summary: Backup codespeed‘s data regularly Key: FLINK-30890 URL: https://issues.apache.org/jira/browse/FLINK-30890 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30863) Do not delete the local changelog file of aborted checkpoint

Yanfei Lei created FLINK-30863: -- Summary: Do not delete the local changelog file of aborted checkpoint Key: FLINK-30863 URL: https://issues.apache.org/jira/browse/FLINK-30863 Project: Flink Iss

[jira] [Created] (FLINK-30836) Release FRocksDB 6.20.3-ververica-2.0

Yanfei Lei created FLINK-30836: -- Summary: Release FRocksDB 6.20.3-ververica-2.0 Key: FLINK-30836 URL: https://issues.apache.org/jira/browse/FLINK-30836 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30321) Upgrade ZLIB of FRocksDB to 1.2.13

Yanfei Lei created FLINK-30321: -- Summary: Upgrade ZLIB of FRocksDB to 1.2.13 Key: FLINK-30321 URL: https://issues.apache.org/jira/browse/FLINK-30321 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-30181) MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed

Yanfei Lei created FLINK-30181: -- Summary: MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed Key: FLINK-30181 URL: https://issues.apache.org/jira/browse/FLINK-30181 Project: Flink

[jira] [Created] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

Yanfei Lei created FLINK-29913: -- Summary: Shared state would be discarded by mistake when maxConcurrentCheckpoint>1 Key: FLINK-29913 URL: https://issues.apache.org/jira/browse/FLINK-29913 Project: Flink

[jira] [Created] (FLINK-29825) Improve benchmark stablility

Yanfei Lei created FLINK-29825: -- Summary: Improve benchmark stablility Key: FLINK-29825 URL: https://issues.apache.org/jira/browse/FLINK-29825 Project: Flink Issue Type: Improvement Co

[jira] [Created] (FLINK-28614) Empty local state folders not cleanup on retrieving local state

Yanfei Lei created FLINK-28614: -- Summary: Empty local state folders not cleanup on retrieving local state Key: FLINK-28614 URL: https://issues.apache.org/jira/browse/FLINK-28614 Project: Flink

[jira] [Created] (FLINK-28038) RocksDB rescaling improvement & rescaling benchmark - umbrella ticket

Yanfei Lei created FLINK-28038: -- Summary: RocksDB rescaling improvement & rescaling benchmark - umbrella ticket Key: FLINK-28038 URL: https://issues.apache.org/jira/browse/FLINK-28038 Project: Flink

[jira] [Created] (FLINK-27693) Support local recovery for non-materialized part(write, restore, discard)

Yanfei Lei created FLINK-27693: -- Summary: Support local recovery for non-materialized part(write, restore, discard) Key: FLINK-27693 URL: https://issues.apache.org/jira/browse/FLINK-27693 Project: Flink

[jira] [Created] (FLINK-27692) Support local recovery for materialized part(write, restore, discard)

Yanfei Lei created FLINK-27692: -- Summary: Support local recovery for materialized part(write, restore, discard) Key: FLINK-27692 URL: https://issues.apache.org/jira/browse/FLINK-27692 Project: Flink

[jira] [Created] (FLINK-27260) Expose changelog configuration in RestAPI and WebUI

Yanfei Lei created FLINK-27260: -- Summary: Expose changelog configuration in RestAPI and WebUI Key: FLINK-27260 URL: https://issues.apache.org/jira/browse/FLINK-27260 Project: Flink Issue Type: I

[jira] [Created] (FLINK-26757) change the default value of state.backend.rocksdb.restore-overlap-fraction-threshold

Yanfei Lei created FLINK-26757: -- Summary: change the default value of state.backend.rocksdb.restore-overlap-fraction-threshold Key: FLINK-26757 URL: https://issues.apache.org/jira/browse/FLINK-26757 Proj

[jira] [Created] (FLINK-26560) make the threshold of the overlap fraction of incremental restoring configurable

Yanfei Lei created FLINK-26560: -- Summary: make the threshold of the overlap fraction of incremental restoring configurable Key: FLINK-26560 URL: https://issues.apache.org/jira/browse/FLINK-26560 Project:

[jira] [Created] (FLINK-23399) Add a benchmark for rescaling

Yanfei Lei created FLINK-23399: -- Summary: Add a benchmark for rescaling Key: FLINK-23399 URL: https://issues.apache.org/jira/browse/FLINK-23399 Project: Flink Issue Type: Improvement C

[jira] [Created] (FLINK-23003) resource leak in RocksIncrementalSnapshotStrategy

Yanfei Lei created FLINK-23003: -- Summary: resource leak in RocksIncrementalSnapshotStrategy Key: FLINK-23003 URL: https://issues.apache.org/jira/browse/FLINK-23003 Project: Flink Issue Type: Bug