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
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
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:
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
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
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
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
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:
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
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
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
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
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
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
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
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:
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
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
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
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
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-
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
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
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
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
Yanfei Lei created FLINK-30181:
--
Summary: MultiInputCheckpointingTimeBenchmark.checkpointMultiInput
benchmark failed
Key: FLINK-30181
URL: https://issues.apache.org/jira/browse/FLINK-30181
Project: Flink
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
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
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
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
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
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
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
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
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:
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
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
37 matches
Mail list logo