[jira] [Created] (FLINK-36743) Rescale from unaligend checkpoint failed

Feifan Wang created FLINK-36743: --- Summary: Rescale from unaligend checkpoint failed Key: FLINK-36743 URL: https://issues.apache.org/jira/browse/FLINK-36743 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36325) Implement basic restore from checkpoint for ForStStateBackend

Feifan Wang created FLINK-36325: --- Summary: Implement basic restore from checkpoint for ForStStateBackend Key: FLINK-36325 URL: https://issues.apache.org/jira/browse/FLINK-36325 Project: Flink

[jira] [Created] (FLINK-35510) Implement basic incremental checkpoint for ForStStateBackend

Feifan Wang created FLINK-35510: --- Summary: Implement basic incremental checkpoint for ForStStateBackend Key: FLINK-35510 URL: https://issues.apache.org/jira/browse/FLINK-35510 Project: Flink I

[jira] [Created] (FLINK-35434) Support pass exception in StateExecutor to runtime

Feifan Wang created FLINK-35434: --- Summary: Support pass exception in StateExecutor to runtime Key: FLINK-35434 URL: https://issues.apache.org/jira/browse/FLINK-35434 Project: Flink Issue Type:

[jira] [Created] (FLINK-33734) Merge unaligned checkpoint

Feifan Wang created FLINK-33734: --- Summary: Merge unaligned checkpoint Key: FLINK-33734 URL: https://issues.apache.org/jira/browse/FLINK-33734 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-32908) Fix wrong materialization id setting when switching from non-log-based checkpoint to log-based checkpoint

Feifan Wang created FLINK-32908: --- Summary: Fix wrong materialization id setting when switching from non-log-based checkpoint to log-based checkpoint Key: FLINK-32908 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-32901) Should set initial

Feifan Wang created FLINK-32901: --- Summary: Should set initial Key: FLINK-32901 URL: https://issues.apache.org/jira/browse/FLINK-32901 Project: Flink Issue Type: Bug Reporter: Feifan

[jira] [Created] (FLINK-32769) PeriodicMaterializationManager pass descriptionFormat with invalid placeholder to MailboxExecutor#execute()

Feifan Wang created FLINK-32769: --- Summary: PeriodicMaterializationManager pass descriptionFormat with invalid placeholder to MailboxExecutor#execute() Key: FLINK-32769 URL: https://issues.apache.org/jira/browse/FLIN

[jira] [Created] (FLINK-32761) Use md5 sum of PhysicalStateHandleID as SharedStateRegistryKey ChangelogStateHandleStreamImpl

Feifan Wang created FLINK-32761: --- Summary: Use md5 sum of PhysicalStateHandleID as SharedStateRegistryKey ChangelogStateHandleStreamImpl Key: FLINK-32761 URL: https://issues.apache.org/jira/browse/FLINK-32761

[jira] [Created] (FLINK-32141) SharedStateRegistry print too much info log

Feifan Wang created FLINK-32141: --- Summary: SharedStateRegistry print too much info log Key: FLINK-32141 URL: https://issues.apache.org/jira/browse/FLINK-32141 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32135) FRocksDB fix log file create failed caused by file name too long

Feifan Wang created FLINK-32135: --- Summary: FRocksDB fix log file create failed caused by file name too long Key: FLINK-32135 URL: https://issues.apache.org/jira/browse/FLINK-32135 Project: Flink

[jira] [Created] (FLINK-32130) previous checkpoint will be broke by the subsequent incremental checkpoint

Feifan Wang created FLINK-32130: --- Summary: previous checkpoint will be broke by the subsequent incremental checkpoint Key: FLINK-32130 URL: https://issues.apache.org/jira/browse/FLINK-32130 Project: Fli

[jira] [Created] (FLINK-31900) Fix some typo in java doc, comments and assertion message

Feifan Wang created FLINK-31900: --- Summary: Fix some typo in java doc, comments and assertion message Key: FLINK-31900 URL: https://issues.apache.org/jira/browse/FLINK-31900 Project: Flink Issue

[jira] [Created] (FLINK-31414) exceptions in the alignment timer are ignored

Feifan Wang created FLINK-31414: --- Summary: exceptions in the alignment timer are ignored Key: FLINK-31414 URL: https://issues.apache.org/jira/browse/FLINK-31414 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31139) not upload empty state changelog file

Feifan Wang created FLINK-31139: --- Summary: not upload empty state changelog file Key: FLINK-31139 URL: https://issues.apache.org/jira/browse/FLINK-31139 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30792) clean up not uploaded state changes after materialization complete

Feifan Wang created FLINK-30792: --- Summary: clean up not uploaded state changes after materialization complete Key: FLINK-30792 URL: https://issues.apache.org/jira/browse/FLINK-30792 Project: Flink

[jira] [Created] (FLINK-30561) ChangelogStreamHandleReaderWithCache cause FileNotFoundException

Feifan Wang created FLINK-30561: --- Summary: ChangelogStreamHandleReaderWithCache cause FileNotFoundException Key: FLINK-30561 URL: https://issues.apache.org/jira/browse/FLINK-30561 Project: Flink

[jira] [Created] (FLINK-29822) Fix wrong description in comments of StreamExecutionEnvironment#setMaxParallelism()

Feifan Wang created FLINK-29822: --- Summary: Fix wrong description in comments of StreamExecutionEnvironment#setMaxParallelism() Key: FLINK-29822 URL: https://issues.apache.org/jira/browse/FLINK-29822 Pro

[jira] [Created] (FLINK-29526) Java doc mistake in SequenceNumberRange#contains()

Feifan Wang created FLINK-29526: --- Summary: Java doc mistake in SequenceNumberRange#contains() Key: FLINK-29526 URL: https://issues.apache.org/jira/browse/FLINK-29526 Project: Flink Issue Type:

[jira] [Created] (FLINK-29244) Add metric lastMaterializationDuration to ChangelogMaterializationMetricGroup

Feifan Wang created FLINK-29244: --- Summary: Add metric lastMaterializationDuration to ChangelogMaterializationMetricGroup Key: FLINK-29244 URL: https://issues.apache.org/jira/browse/FLINK-29244 Project:

[jira] [Created] (FLINK-28178) Show the delegated StateBackend and whether changelog is enabled in the UI

Feifan Wang created FLINK-28178: --- Summary: Show the delegated StateBackend and whether changelog is enabled in the UI Key: FLINK-28178 URL: https://issues.apache.org/jira/browse/FLINK-28178 Project: Fli

[jira] [Created] (FLINK-28172) Scatter dstl files into separate directories by job id

Feifan Wang created FLINK-28172: --- Summary: Scatter dstl files into separate directories by job id Key: FLINK-28172 URL: https://issues.apache.org/jira/browse/FLINK-28172 Project: Flink Issue Ty

[jira] [Created] (FLINK-27841) RocksDB cache miss increase in 1.15

Feifan Wang created FLINK-27841: --- Summary: RocksDB cache miss increase in 1.15 Key: FLINK-27841 URL: https://issues.apache.org/jira/browse/FLINK-27841 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

Feifan Wang created FLINK-27734: --- Summary: Not showing checkpoint interval properly in WebUI when checkpoint is disabled Key: FLINK-27734 URL: https://issues.apache.org/jira/browse/FLINK-27734 Project:

[jira] [Created] (FLINK-27187) The attemptsPerUpload metric may be lower than it actually is

Feifan Wang created FLINK-27187: --- Summary: The attemptsPerUpload metric may be lower than it actually is Key: FLINK-27187 URL: https://issues.apache.org/jira/browse/FLINK-27187 Project: Flink

[jira] [Created] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

Feifan Wang created FLINK-27155: --- Summary: Reduce multiple reads to the same Changelog file in the same taskmanager during restore Key: FLINK-27155 URL: https://issues.apache.org/jira/browse/FLINK-27155

[jira] [Created] (FLINK-27105) wrong metric type

Feifan Wang created FLINK-27105: --- Summary: wrong metric type Key: FLINK-27105 URL: https://issues.apache.org/jira/browse/FLINK-27105 Project: Flink Issue Type: Bug Reporter: Feifan

[jira] [Created] (FLINK-26799) StateChangeFormat#read not seek to offset correctly

Feifan Wang created FLINK-26799: --- Summary: StateChangeFormat#read not seek to offset correctly Key: FLINK-26799 URL: https://issues.apache.org/jira/browse/FLINK-26799 Project: Flink Issue Type:

[jira] [Created] (FLINK-26766) Mistake in ChangelogStateHandleStreamImpl#getIntersection

Feifan Wang created FLINK-26766: --- Summary: Mistake in ChangelogStateHandleStreamImpl#getIntersection Key: FLINK-26766 URL: https://issues.apache.org/jira/browse/FLINK-26766 Project: Flink Issue

[jira] [Created] (FLINK-24562) YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

Feifan Wang created FLINK-24562: --- Summary: YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance Key: FLINK-24562 URL: https://issues.apache.org/jira/browse/FLINK-24562 Project:

[jira] [Created] (FLINK-24384) Count checkpoints failed in trigger phase into numberOfFailedCheckpoints

Feifan Wang created FLINK-24384: --- Summary: Count checkpoints failed in trigger phase into numberOfFailedCheckpoints Key: FLINK-24384 URL: https://issues.apache.org/jira/browse/FLINK-24384 Project: Flink

[jira] [Created] (FLINK-24274) Wrong parameter order in documentation of State Processor API

Feifan Wang created FLINK-24274: --- Summary: Wrong parameter order in documentation of State Processor API Key: FLINK-24274 URL: https://issues.apache.org/jira/browse/FLINK-24274 Project: Flink

[jira] [Created] (FLINK-24159) document of entropy injection may mislead users

Feifan Wang created FLINK-24159: --- Summary: document of entropy injection may mislead users Key: FLINK-24159 URL: https://issues.apache.org/jira/browse/FLINK-24159 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-24149) Make checkpoint relocatable

Feifan Wang created FLINK-24149: --- Summary: Make checkpoint relocatable Key: FLINK-24149 URL: https://issues.apache.org/jira/browse/FLINK-24149 Project: Flink Issue Type: Improvement C

[jira] [Created] (FLINK-23949) first incremental checkpoint after a savepoint will degenerate into a full checkpoint

Feifan Wang created FLINK-23949: --- Summary: first incremental checkpoint after a savepoint will degenerate into a full checkpoint Key: FLINK-23949 URL: https://issues.apache.org/jira/browse/FLINK-23949 P

[jira] [Created] (FLINK-21986) taskmanager native memory not release timely after restart

Feifan Wang created FLINK-21986: --- Summary: taskmanager native memory not release timely after restart Key: FLINK-21986 URL: https://issues.apache.org/jira/browse/FLINK-21986 Project: Flink Issu