[jira] [Updated] (FLINK-28872) UnalignedCheckpointStressITCase fails with NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-28872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lihe Ma updated FLINK-28872: Description: UnalignedCheckpointStressITCase fails occasionally. >From the logs from one failed attempt,

[jira] [Created] (FLINK-28872) UnalignedCheckpointStressITCase fails with NoSuchFileException

Lihe Ma created FLINK-28872: --- Summary: UnalignedCheckpointStressITCase fails with NoSuchFileException Key: FLINK-28872 URL: https://issues.apache.org/jira/browse/FLINK-28872 Project: Flink Issue T

[jira] [Commented] (FLINK-28843) Failed to restore from changelog checkpoint in claim mode

[ https://issues.apache.org/jira/browse/FLINK-28843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576403#comment-17576403 ] Lihe Ma commented on FLINK-28843: - I think the root cause is that IncrementalKeyedStateH

[jira] [Updated] (FLINK-28843) Failed to restore from changelog checkpoint in claim mode

[ https://issues.apache.org/jira/browse/FLINK-28843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lihe Ma updated FLINK-28843: Description: # When native checkpoint is enabled and incremental checkpointing is enabled in rocksdb stat

[jira] [Created] (FLINK-28843) Failed to restore from changelog checkpoint in claim mode

Lihe Ma created FLINK-28843: --- Summary: Failed to restore from changelog checkpoint in claim mode Key: FLINK-28843 URL: https://issues.apache.org/jira/browse/FLINK-28843 Project: Flink Issue Type: B

[jira] [Created] (FLINK-28699) Native rocksdb full snapshot in non-incremental checkpointing

Lihe Ma created FLINK-28699: --- Summary: Native rocksdb full snapshot in non-incremental checkpointing Key: FLINK-28699 URL: https://issues.apache.org/jira/browse/FLINK-28699 Project: Flink Issue Ty

[jira] [Closed] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

[ https://issues.apache.org/jira/browse/FLINK-28499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lihe ma closed FLINK-28499. --- Resolution: Not A Bug > resource leak when job failed with unknown status In Application Mode >

[jira] [Commented] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

[ https://issues.apache.org/jira/browse/FLINK-28499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17567062#comment-17567062 ] lihe ma commented on FLINK-28499: - [~wangyang0918]  Thanks for your explanation. It seem

[jira] [Commented] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

[ https://issues.apache.org/jira/browse/FLINK-28499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566225#comment-17566225 ] lihe ma commented on FLINK-28499: - [~wangyang0918]  Thanks and I appreciate your comment

[jira] [Updated] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

[ https://issues.apache.org/jira/browse/FLINK-28499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lihe ma updated FLINK-28499: Description: I found a job restarted for thousands of times, and jobmanager tried to create a new taskman

[jira] [Closed] (FLINK-28498) resource leak when job failed with unknown status In Application Mode

[ https://issues.apache.org/jira/browse/FLINK-28498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lihe ma closed FLINK-28498. --- Resolution: Duplicate > resource leak when job failed with unknown status In Application Mode >

[jira] [Closed] (FLINK-28497) resource leak when job failed with unknown status In Application Mode

[ https://issues.apache.org/jira/browse/FLINK-28497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lihe ma closed FLINK-28497. --- Resolution: Duplicate > resource leak when job failed with unknown status In Application Mode >

[jira] [Created] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

lihe ma created FLINK-28499: --- Summary: resource leak when job failed with unknown status In Application Mode Key: FLINK-28499 URL: https://issues.apache.org/jira/browse/FLINK-28499 Project: Flink

[jira] [Created] (FLINK-28498) resource leak when job failed with unknown status In Application Mode

lihe ma created FLINK-28498: --- Summary: resource leak when job failed with unknown status In Application Mode Key: FLINK-28498 URL: https://issues.apache.org/jira/browse/FLINK-28498 Project: Flink

[jira] [Created] (FLINK-28497) resource leak when job failed with unknown status In Application Mode

lihe ma created FLINK-28497: --- Summary: resource leak when job failed with unknown status In Application Mode Key: FLINK-28497 URL: https://issues.apache.org/jira/browse/FLINK-28497 Project: Flink

[jira] [Closed] (FLINK-22918) StreamingFileSink does not commit partition when no message is sent

[ https://issues.apache.org/jira/browse/FLINK-22918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lihe ma closed FLINK-22918. --- Resolution: Not A Bug this situation happens when flink job is misconfigured without checkpoint or savepoin

[jira] [Updated] (FLINK-22918) StreamingFileSink does not commit partition when no message is sent

[ https://issues.apache.org/jira/browse/FLINK-22918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lihe ma updated FLINK-22918: Summary: StreamingFileSink does not commit partition when no message is sent (was: StreamingFileSink doe

[jira] [Created] (FLINK-22918) StreamingFileSink does not commit partition when no message is sent between checkpoints

lihe ma created FLINK-22918: --- Summary: StreamingFileSink does not commit partition when no message is sent between checkpoints Key: FLINK-22918 URL: https://issues.apache.org/jira/browse/FLINK-22918 Project

[jira] [Commented] (FLINK-21397) BufferUnderflowException when read parquet

[ https://issues.apache.org/jira/browse/FLINK-21397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17289662#comment-17289662 ] lihe ma commented on FLINK-21397: - thanks for your reply,  I set source.reader.element.q

[jira] [Created] (FLINK-21397) BufferUnderflowException when read parquet

lihe ma created FLINK-21397: --- Summary: BufferUnderflowException when read parquet Key: FLINK-21397 URL: https://issues.apache.org/jira/browse/FLINK-21397 Project: Flink Issue Type: Bug C