Zakelly Lan created FLINK-32753:
---
Summary: Print JVM flags on AZP
Key: FLINK-32753
URL: https://issues.apache.org/jira/browse/FLINK-32753
Project: Flink
Issue Type: Improvement
Compon
Zakelly Lan created FLINK-33057:
---
Summary: Add options to disable creating job-id subdirectories
under the checkpoint directory
Key: FLINK-33057
URL: https://issues.apache.org/jira/browse/FLINK-33057
Pr
Zakelly Lan created FLINK-33060:
---
Summary: Fix the javadoc of ListState.update/addAll about not
allowing null value
Key: FLINK-33060
URL: https://issues.apache.org/jira/browse/FLINK-33060
Project: Flink
Zakelly Lan created FLINK-33122:
---
Summary: [Benchmark] Null checkpoint directory in rescaling
benchmarks
Key: FLINK-33122
URL: https://issues.apache.org/jira/browse/FLINK-33122
Project: Flink
Zakelly Lan created FLINK-33161:
---
Summary: [benchmark] Java17 profile for benchmarks
Key: FLINK-33161
URL: https://issues.apache.org/jira/browse/FLINK-33161
Project: Flink
Issue Type: Bug
Zakelly Lan created FLINK-33482:
---
Summary: Flink benchmark regression check in the new machines
Key: FLINK-33482
URL: https://issues.apache.org/jira/browse/FLINK-33482
Project: Flink
Issue Type
Zakelly Lan created FLINK-33498:
---
Summary: Do not allow manually triggering incremental checkpoints
with full checkpoint configured
Key: FLINK-33498
URL: https://issues.apache.org/jira/browse/FLINK-33498
Zakelly Lan created FLINK-33539:
---
Summary: Potential regression (Nov. 7th): listAddAll on RocksDB
with Java8
Key: FLINK-33539
URL: https://issues.apache.org/jira/browse/FLINK-33539
Project: Flink
Zakelly Lan created FLINK-32071:
---
Summary: Implement the snapshot manager for merged checkpoint
files in TM
Key: FLINK-32071
URL: https://issues.apache.org/jira/browse/FLINK-32071
Project: Flink
Zakelly Lan created FLINK-32070:
---
Summary: FLIP-306 Unified File Merging Mechanism for Checkpoints
Key: FLINK-32070
URL: https://issues.apache.org/jira/browse/FLINK-32070
Project: Flink
Issue T
Zakelly Lan created FLINK-32073:
---
Summary: Implement file merging in snapshot
Key: FLINK-32073
URL: https://issues.apache.org/jira/browse/FLINK-32073
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32072:
---
Summary: Create and wire FileMergingSnapshotManager with
TaskManagerServices
Key: FLINK-32072
URL: https://issues.apache.org/jira/browse/FLINK-32072
Project: Flink
Zakelly Lan created FLINK-32074:
---
Summary: Support file merging across checkpoints
Key: FLINK-32074
URL: https://issues.apache.org/jira/browse/FLINK-32074
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32075:
---
Summary: Delete merged files on checkpoint abort
Key: FLINK-32075
URL: https://issues.apache.org/jira/browse/FLINK-32075
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32076:
---
Summary: Add file pool for concurrent file reusing
Key: FLINK-32076
URL: https://issues.apache.org/jira/browse/FLINK-32076
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32077:
---
Summary: Implement shared state file merging
Key: FLINK-32077
URL: https://issues.apache.org/jira/browse/FLINK-32077
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32078:
---
Summary: Implement private state file merging
Key: FLINK-32078
URL: https://issues.apache.org/jira/browse/FLINK-32078
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32079:
---
Summary: Read/write checkpoint metadata of merged files
Key: FLINK-32079
URL: https://issues.apache.org/jira/browse/FLINK-32079
Project: Flink
Issue Type: Sub-
Zakelly Lan created FLINK-32081:
---
Summary: Compatibility between file-merging on and off across job
runs
Key: FLINK-32081
URL: https://issues.apache.org/jira/browse/FLINK-32081
Project: Flink
Zakelly Lan created FLINK-32080:
---
Summary: Restoration of FileMergingSnapshotManager
Key: FLINK-32080
URL: https://issues.apache.org/jira/browse/FLINK-32080
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32082:
---
Summary: Documentation of checkpoint file-merging
Key: FLINK-32082
URL: https://issues.apache.org/jira/browse/FLINK-32082
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32083:
---
Summary: Chinese translation of documentation of checkpoint
file-merging
Key: FLINK-32083
URL: https://issues.apache.org/jira/browse/FLINK-32083
Project: Flink
Zakelly Lan created FLINK-32085:
---
Summary: Implement and migrate batch uploading in changelog files
into the file merging framework
Key: FLINK-32085
URL: https://issues.apache.org/jira/browse/FLINK-32085
Zakelly Lan created FLINK-32084:
---
Summary: Migrate current file merging of channel state into the
file merging framework
Key: FLINK-32084
URL: https://issues.apache.org/jira/browse/FLINK-32084
Project:
Zakelly Lan created FLINK-32086:
---
Summary: Cleanup non-reported managed directory on exit of TM
Key: FLINK-32086
URL: https://issues.apache.org/jira/browse/FLINK-32086
Project: Flink
Issue Type
Zakelly Lan created FLINK-32088:
---
Summary: Re-uploading in state file-merging for space
amplification control
Key: FLINK-32088
URL: https://issues.apache.org/jira/browse/FLINK-32088
Project: Flink
Zakelly Lan created FLINK-32087:
---
Summary: Space amplification statistics of file merging
Key: FLINK-32087
URL: https://issues.apache.org/jira/browse/FLINK-32087
Project: Flink
Issue Type: Sub-
Zakelly Lan created FLINK-32092:
---
Summary: Integrate snapshot file-merging with existing IT cases
Key: FLINK-32092
URL: https://issues.apache.org/jira/browse/FLINK-32092
Project: Flink
Issue Ty
Zakelly Lan created FLINK-32089:
---
Summary: Do fast copy in best-effort during first checkpoint after
restoration
Key: FLINK-32089
URL: https://issues.apache.org/jira/browse/FLINK-32089
Project: Flink
Zakelly Lan created FLINK-32091:
---
Summary: Add necessary metrics for file-merging
Key: FLINK-32091
URL: https://issues.apache.org/jira/browse/FLINK-32091
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-32090:
---
Summary: Python API for enabling and configuring file merging
snapshot
Key: FLINK-32090
URL: https://issues.apache.org/jira/browse/FLINK-32090
Project: Flink
Zakelly Lan created FLINK-26998:
---
Summary: Remove log-related configuration from predefined options
in RocksDB state backend
Key: FLINK-26998
URL: https://issues.apache.org/jira/browse/FLINK-26998
Proj
Zakelly Lan created FLINK-33672:
---
Summary: Use MapState.entries() instead of keys() and get() in
over window
Key: FLINK-33672
URL: https://issues.apache.org/jira/browse/FLINK-33672
Project: Flink
Zakelly Lan created FLINK-33723:
---
Summary: Disallow triggering incremental checkpoint explicitly
from REST API
Key: FLINK-33723
URL: https://issues.apache.org/jira/browse/FLINK-33723
Project: Flink
Zakelly Lan created FLINK-33811:
---
Summary: The CI for frocksdb has broken
Key: FLINK-33811
URL: https://issues.apache.org/jira/browse/FLINK-33811
Project: Flink
Issue Type: Bug
Compon
Zakelly Lan created FLINK-33864:
---
Summary: [Benchmark] Get rid of generating key-values in advance
to optimize heap usage in state benchmark
Key: FLINK-33864
URL: https://issues.apache.org/jira/browse/FLINK-33864
Zakelly Lan created FLINK-33897:
---
Summary: Allow triggering unaligned checkpoint via CLI
Key: FLINK-33897
URL: https://issues.apache.org/jira/browse/FLINK-33897
Project: Flink
Issue Type: Impro
Zakelly Lan created FLINK-33898:
---
Summary: Allow triggering unaligned checkpoint via REST api
Key: FLINK-33898
URL: https://issues.apache.org/jira/browse/FLINK-33898
Project: Flink
Issue Type:
Zakelly Lan created FLINK-34148:
---
Summary: Potential regression (Jan. 13): stringWrite with Java8
Key: FLINK-34148
URL: https://issues.apache.org/jira/browse/FLINK-34148
Project: Flink
Issue Ty
Zakelly Lan created FLINK-34164:
---
Summary: [Benchmark] Compilation error since Jan. 16th
Key: FLINK-34164
URL: https://issues.apache.org/jira/browse/FLINK-34164
Project: Flink
Issue Type: Bug
Zakelly Lan created FLINK-34169:
---
Summary: [benchmark] CI fails during test running
Key: FLINK-34169
URL: https://issues.apache.org/jira/browse/FLINK-34169
Project: Flink
Issue Type: Bug
Zakelly Lan created FLINK-34189:
---
Summary: FLIP-416: Deprecate and remove the RestoreMode#LEGACY
Key: FLINK-34189
URL: https://issues.apache.org/jira/browse/FLINK-34189
Project: Flink
Issue Typ
Zakelly Lan created FLINK-34190:
---
Summary: Deprecate RestoreMode#LEGACY
Key: FLINK-34190
URL: https://issues.apache.org/jira/browse/FLINK-34190
Project: Flink
Issue Type: Sub-task
R
Zakelly Lan created FLINK-34191:
---
Summary: Remove RestoreMode#LEGACY
Key: FLINK-34191
URL: https://issues.apache.org/jira/browse/FLINK-34191
Project: Flink
Issue Type: Sub-task
Re
Zakelly Lan created FLINK-34255:
---
Summary: FLIP-406: Reorganize State & Checkpointing & Recovery
Configuration
Key: FLINK-34255
URL: https://issues.apache.org/jira/browse/FLINK-34255
Project: Flink
Zakelly Lan created FLINK-34453:
---
Summary: [Benchmark] Add warmup in SchedulerBenchmarkExecutor
Key: FLINK-34453
URL: https://issues.apache.org/jira/browse/FLINK-34453
Project: Flink
Issue Type
Zakelly Lan created FLINK-34454:
---
Summary: Introduce RecoveryOptions in flink-core
Key: FLINK-34454
URL: https://issues.apache.org/jira/browse/FLINK-34454
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-34455:
---
Summary: Move RestoreMode from flink-runtime to flink-core
Key: FLINK-34455
URL: https://issues.apache.org/jira/browse/FLINK-34455
Project: Flink
Issue Type: S
Zakelly Lan created FLINK-34456:
---
Summary: Move all checkpoint-related options into
CheckpointingOptions
Key: FLINK-34456
URL: https://issues.apache.org/jira/browse/FLINK-34456
Project: Flink
Zakelly Lan created FLINK-34457:
---
Summary: Rename options for latency tracking
Key: FLINK-34457
URL: https://issues.apache.org/jira/browse/FLINK-34457
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-34458:
---
Summary: Rename options for Generalized incremental checkpoints
(changelog)
Key: FLINK-34458
URL: https://issues.apache.org/jira/browse/FLINK-34458
Project: Flink
Zakelly Lan created FLINK-34482:
---
Summary: Rename options for checkpointing
Key: FLINK-34482
URL: https://issues.apache.org/jira/browse/FLINK-34482
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-34483:
---
Summary: Merge 'state.checkpoints.dir' and
'state.checkpoints-storage' into one
Key: FLINK-34483
URL: https://issues.apache.org/jira/browse/FLINK-34483
Project: Flink
Zakelly Lan created FLINK-34484:
---
Summary: Split 'state.backend.local-recovery' into two options for
checkpointing and recovery
Key: FLINK-34484
URL: https://issues.apache.org/jira/browse/FLINK-34484
Pr
Zakelly Lan created FLINK-34510:
---
Summary: Flink 2.0: Rename RestoreMode to RecoveryClaimMode
Key: FLINK-34510
URL: https://issues.apache.org/jira/browse/FLINK-34510
Project: Flink
Issue Type:
Zakelly Lan created FLINK-34511:
---
Summary: Flink 2.0: Deprecate legacy State&Checkpointing&Recovery
options
Key: FLINK-34511
URL: https://issues.apache.org/jira/browse/FLINK-34511
Project: Flink
Zakelly Lan created FLINK-34516:
---
Summary: Move CheckpointingMode to flink-core
Key: FLINK-34516
URL: https://issues.apache.org/jira/browse/FLINK-34516
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-34668:
---
Summary: Report State handle of file merging directory to JM
Key: FLINK-34668
URL: https://issues.apache.org/jira/browse/FLINK-34668
Project: Flink
Issue Type:
Zakelly Lan created FLINK-34704:
---
Summary: Process checkpoint barrier in AsyncWaitOperator when the
element queue is full
Key: FLINK-34704
URL: https://issues.apache.org/jira/browse/FLINK-34704
Project:
Zakelly Lan created FLINK-34973:
---
Summary: FLIP-423: Disaggregated State Storage and Management
Key: FLINK-34973
URL: https://issues.apache.org/jira/browse/FLINK-34973
Project: Flink
Issue Type
Zakelly Lan created FLINK-34974:
---
Summary: FLIP-424: Asynchronous State APIs
Key: FLINK-34974
URL: https://issues.apache.org/jira/browse/FLINK-34974
Project: Flink
Issue Type: New Feature
Zakelly Lan created FLINK-34979:
---
Summary: Implement State Future and related utilities
Key: FLINK-34979
URL: https://issues.apache.org/jira/browse/FLINK-34979
Project: Flink
Issue Type: Sub-ta
Zakelly Lan created FLINK-34978:
---
Summary: Introduce Asynchronous State APIs
Key: FLINK-34978
URL: https://issues.apache.org/jira/browse/FLINK-34978
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-34986:
---
Summary: Basic framework for async execution of state
Key: FLINK-34986
URL: https://issues.apache.org/jira/browse/FLINK-34986
Project: Flink
Issue Type: Sub-ta
Zakelly Lan created FLINK-35060:
---
Summary: Provide compatibility of old CheckpointMode for connector
testing framework
Key: FLINK-35060
URL: https://issues.apache.org/jira/browse/FLINK-35060
Project: Fl
Zakelly Lan created FLINK-29430:
---
Summary: Sanity check in
InternalKeyContextImpl#setCurrentKeyGroupIndex
Key: FLINK-29430
URL: https://issues.apache.org/jira/browse/FLINK-29430
Project: Flink
Zakelly Lan created FLINK-29437:
---
Summary: The partition of data before and after the Kafka Shuffle
are not aligned
Key: FLINK-29437
URL: https://issues.apache.org/jira/browse/FLINK-29437
Project: Flink
Zakelly Lan created FLINK-35153:
---
Summary: Internal Async State Implementation and StateDescriptor
for Map/List State
Key: FLINK-35153
URL: https://issues.apache.org/jira/browse/FLINK-35153
Project: Fli
Zakelly Lan created FLINK-35156:
---
Summary: Wire new operators for async state with DataStream V2
Key: FLINK-35156
URL: https://issues.apache.org/jira/browse/FLINK-35156
Project: Flink
Issue Typ
Zakelly Lan created FLINK-35168:
---
Summary: Basic State Iterator for async processing
Key: FLINK-35168
URL: https://issues.apache.org/jira/browse/FLINK-35168
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-35186:
---
Summary: Create State V2 from new StateDescriptor
Key: FLINK-35186
URL: https://issues.apache.org/jira/browse/FLINK-35186
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-35307:
---
Summary: Add Compile CI check on jdk17
Key: FLINK-35307
URL: https://issues.apache.org/jira/browse/FLINK-35307
Project: Flink
Issue Type: Improvement
Zakelly Lan created FLINK-35355:
---
Summary: Async aggregating state
Key: FLINK-35355
URL: https://issues.apache.org/jira/browse/FLINK-35355
Project: Flink
Issue Type: Sub-task
Componen
Zakelly Lan created FLINK-35356:
---
Summary: Async reducing state
Key: FLINK-35356
URL: https://issues.apache.org/jira/browse/FLINK-35356
Project: Flink
Issue Type: Sub-task
Components:
Zakelly Lan created FLINK-35379:
---
Summary: File merging manager is not properly notified about
checkpoint
Key: FLINK-35379
URL: https://issues.apache.org/jira/browse/FLINK-35379
Project: Flink
Zakelly Lan created FLINK-35400:
---
Summary: Rebuild FileMergingSnapshotManager in failover
Key: FLINK-35400
URL: https://issues.apache.org/jira/browse/FLINK-35400
Project: Flink
Issue Type: Sub-
Zakelly Lan created FLINK-35410:
---
Summary: Avoid sync waiting in coordinator thread of ForSt executor
Key: FLINK-35410
URL: https://issues.apache.org/jira/browse/FLINK-35410
Project: Flink
Issu
Zakelly Lan created FLINK-35411:
---
Summary: Optimize wait logic in draining of async state requests
Key: FLINK-35411
URL: https://issues.apache.org/jira/browse/FLINK-35411
Project: Flink
Issue T
Zakelly Lan created FLINK-35412:
---
Summary: Batch execution of async state request callback
Key: FLINK-35412
URL: https://issues.apache.org/jira/browse/FLINK-35412
Project: Flink
Issue Type: Sub
Zakelly Lan created FLINK-35534:
---
Summary: Support profiler for benchmarks
Key: FLINK-35534
URL: https://issues.apache.org/jira/browse/FLINK-35534
Project: Flink
Issue Type: Improvement
Zakelly Lan created FLINK-35535:
---
Summary: Enable benchmark profiling in daily run
Key: FLINK-35535
URL: https://issues.apache.org/jira/browse/FLINK-35535
Project: Flink
Issue Type: Improvement
Zakelly Lan created FLINK-35537:
---
Summary: Error parsing list of enum in legacy yaml configuration
Key: FLINK-35537
URL: https://issues.apache.org/jira/browse/FLINK-35537
Project: Flink
Issue
Zakelly Lan created FLINK-35570:
---
Summary: Consider PlaceholderStreamStateHandle in checkpoint file
merging
Key: FLINK-35570
URL: https://issues.apache.org/jira/browse/FLINK-35570
Project: Flink
Zakelly Lan created FLINK-35590:
---
Summary: Cleanup deprecated options usage in docs about state and
checkpoint
Key: FLINK-35590
URL: https://issues.apache.org/jira/browse/FLINK-35590
Project: Flink
Zakelly Lan created FLINK-35617:
---
Summary: Support object reuse in async state execution
Key: FLINK-35617
URL: https://issues.apache.org/jira/browse/FLINK-35617
Project: Flink
Issue Type: Sub-t
Zakelly Lan created FLINK-35624:
---
Summary: Release Testing: Verify FLIP-306 Unified File Merging
Mechanism for Checkpoints
Key: FLINK-35624
URL: https://issues.apache.org/jira/browse/FLINK-35624
Project
Zakelly Lan created FLINK-35666:
---
Summary: Implement Aggregating Async State API for
ForStStateBackend
Key: FLINK-35666
URL: https://issues.apache.org/jira/browse/FLINK-35666
Project: Flink
Is
Zakelly Lan created FLINK-35667:
---
Summary: Implement Reducing Async State API for ForStStateBackend
Key: FLINK-35667
URL: https://issues.apache.org/jira/browse/FLINK-35667
Project: Flink
Issue
Zakelly Lan created FLINK-35778:
---
Summary: Escape URI reserved characters when creating file-merging
directories
Key: FLINK-35778
URL: https://issues.apache.org/jira/browse/FLINK-35778
Project: Flink
Zakelly Lan created FLINK-35784:
---
Summary: The cp file-merging directory not properly registered in
SharedStateRegistry
Key: FLINK-35784
URL: https://issues.apache.org/jira/browse/FLINK-35784
Project: F
Zakelly Lan created FLINK-35812:
---
Summary: Move tuple interfaces to flink-core-api
Key: FLINK-35812
URL: https://issues.apache.org/jira/browse/FLINK-35812
Project: Flink
Issue Type: Improvement
Zakelly Lan created FLINK-35843:
---
Summary: Check cp directory empty may fail in file-merging testing
Key: FLINK-35843
URL: https://issues.apache.org/jira/browse/FLINK-35843
Project: Flink
Issue
Zakelly Lan created FLINK-35858:
---
Summary: Namespace support for async state
Key: FLINK-35858
URL: https://issues.apache.org/jira/browse/FLINK-35858
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-35904:
---
Summary: Test harness for async state processing operators
Key: FLINK-35904
URL: https://issues.apache.org/jira/browse/FLINK-35904
Project: Flink
Issue Type: S
Zakelly Lan created FLINK-35972:
---
Summary: Directly specify key and process runnable in async state
execution model
Key: FLINK-35972
URL: https://issues.apache.org/jira/browse/FLINK-35972
Project: Flink
Zakelly Lan created FLINK-36118:
---
Summary: FLIP-455: Declare async state processing and checkpoint
the in-flight requests
Key: FLINK-36118
URL: https://issues.apache.org/jira/browse/FLINK-36118
Project:
Zakelly Lan created FLINK-36119:
---
Summary: Conditional branchings APIs under `StateFuture`
Key: FLINK-36119
URL: https://issues.apache.org/jira/browse/FLINK-36119
Project: Flink
Issue Type: Sub
Zakelly Lan created FLINK-36121:
---
Summary: Snapshot the in-flight async state requests
Key: FLINK-36121
URL: https://issues.apache.org/jira/browse/FLINK-36121
Project: Flink
Issue Type: Sub-tas
Zakelly Lan created FLINK-36120:
---
Summary: Internal APIs for declaring and defining the record
processing
Key: FLINK-36120
URL: https://issues.apache.org/jira/browse/FLINK-36120
Project: Flink
Zakelly Lan created FLINK-23075:
---
Summary: Python API for enabling ChangelogStateBackend
Key: FLINK-23075
URL: https://issues.apache.org/jira/browse/FLINK-23075
Project: Flink
Issue Type: Impro
1 - 100 of 102 matches
Mail list logo
