[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] [Commented] (FLINK-32086) Cleanup non-reported managed directory on exit of TM

[ https://issues.apache.org/jira/browse/FLINK-32086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839592#comment-17839592 ] Feifan Wang commented on FLINK-32086: - Hi [~Zakelly] , are you still work on this ticket ? We want

[jira] [Updated] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

[ https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-35041: Description: {code:java} Apr 08 03:22:45 03:22:45.450 [ERROR]

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830472#comment-17830472 ] Feifan Wang commented on FLINK-33734: - Kindly ping [~Zakelly] , [~roman] . > Merge unaligned

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818283#comment-17818283 ] Feifan Wang commented on FLINK-33734: - [~roman] : {quote}Do I understand correctly, that the

[jira] [Updated] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-33734: Attachment: flamegraph.control-group.html

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818246#comment-17818246 ] Feifan Wang commented on FLINK-33734: - Hi [~fanrui] , I rerun the test job , and find some long

[jira] [Updated] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-33734: Attachment: image-2024-02-18-15-12-20-665.png > Merge unaligned checkpoint state handle >

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818227#comment-17818227 ] Feifan Wang commented on FLINK-33734: - Sorry to keep you waiting [~fanrui] . Checkpoint production

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813646#comment-17813646 ] Feifan Wang commented on FLINK-33734: - I found that only merging handles was not enough. Although

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795222#comment-17795222 ] Feifan Wang commented on FLINK-33734: - Thanks [~roman] , merge handle in JM in MetadataSerializer

[jira] [Updated] (FLINK-17972) Consider restructuring channel state

[ https://issues.apache.org/jira/browse/FLINK-17972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-17972: Description: (depends on rescaling for unaligned checkpoints (FLINK-17979))   Current structure

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17794146#comment-17794146 ] Feifan Wang commented on FLINK-33734: - We do also want to improve the speed of recovery, but

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793998#comment-17793998 ] Feifan Wang commented on FLINK-33734: - Thanks to [~Zakelly] , [~pnowojski] and [~fanrui]  for

[jira] [Updated] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-33734: Description: h3. Background Unaligned checkpoint will write the inflight-data of all

[jira] [Updated] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-33734: Component/s: Runtime / Checkpointing Description: h3. Background Unaligned checkpoint will

[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] [Closed] (FLINK-32901) Should set initial initialSequenceNumber of StateChangelogWriter after restore

[ https://issues.apache.org/jira/browse/FLINK-32901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang closed FLINK-32901. --- Resolution: Not A Problem > Should set initial initialSequenceNumber of StateChangelogWriter after

[jira] [Commented] (FLINK-32901) Should set initial initialSequenceNumber of StateChangelogWriter after restore

[ https://issues.apache.org/jira/browse/FLINK-32901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759531#comment-17759531 ] Feifan Wang commented on FLINK-32901: - Sorry [~masteryhx] , before I thought that the sequence

[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:

[jira] [Updated] (FLINK-32901) Should set initial initialSequenceNumber of StateChangelogWriter after restore

[ https://issues.apache.org/jira/browse/FLINK-32901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32901: Description: The current StateChangelogWriter lacks an interface to set the initial sequence

[jira] [Updated] (FLINK-32901) Should set initial initialSequenceNumber of StateChangelogWriter after restore

[ https://issues.apache.org/jira/browse/FLINK-32901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32901: Priority: Minor (was: Critical) > Should set initial initialSequenceNumber of

[jira] [Updated] (FLINK-32901) Should set initial initialSequenceNumber of StateChangelogWriter after restore

[ https://issues.apache.org/jira/browse/FLINK-32901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32901: Component/s: Runtime / Checkpointing Runtime / State Backends Description:

[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:

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753869#comment-17753869 ] Feifan Wang commented on FLINK-30863: - Since [~Yanfei Lei]  is still working on the ticket, I

[jira] [Updated] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-30863: Labels: pull-request-available (was: pull-request-available stale-assigned) > Register local

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

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753725#comment-17753725 ] Feifan Wang commented on FLINK-31139: - Hi [~roman] , is there any method to re-run  failed stages

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

[ https://issues.apache.org/jira/browse/FLINK-32769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32769: Description: descriptionFormat in _MailboxExecutor#execute( ThrowingRunnable command, String

[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:

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

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751304#comment-17751304 ] Feifan Wang commented on FLINK-29913: - Hi [~roman] , In addition backport pr of

[jira] [Commented] (FLINK-25862) Refactor SharedStateRegistry to not limit StreamStateHandle to register/unregister

[ https://issues.apache.org/jira/browse/FLINK-25862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751299#comment-17751299 ] Feifan Wang commented on FLINK-25862: - Hi [~yunta] , I'd be glad to do this job, can you assign this

[jira] [Updated] (FLINK-32761) Use UUID based on PhysicalStateHandleID as SharedStateRegistryKey ChangelogStateHandleStreamImpl

[ https://issues.apache.org/jira/browse/FLINK-32761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32761: Description: _ChangelogStateHandleStreamImpl#getKey()_ use

[jira] [Updated] (FLINK-32761) Use UUID based on PhysicalStateHandleID as SharedStateRegistryKey ChangelogStateHandleStreamImpl

[ https://issues.apache.org/jira/browse/FLINK-32761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32761: Summary: Use UUID based on PhysicalStateHandleID as SharedStateRegistryKey

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

[ https://issues.apache.org/jira/browse/FLINK-32761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32761: Description: _ChangelogStateHandleStreamImpl#getKey()_ use

[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] [Commented] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1775#comment-1775 ] Feifan Wang commented on FLINK-29913: - [~roman] ,  I submitted two PRs for

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

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750647#comment-17750647 ] Feifan Wang commented on FLINK-29913: -  Thanks to [~roman]  for helping to review the PR, I learned

[jira] [Commented] (FLINK-32681) RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailure unstablie

[ https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749541#comment-17749541 ] Feifan Wang commented on FLINK-32681: - Sorry [~mapohl]  I didn't notice that the ticket has been

[jira] [Comment Edited] (FLINK-32681) RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailure unstablie

[ https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749522#comment-17749522 ] Feifan Wang edited comment on FLINK-32681 at 8/1/23 8:03 AM: - Hi [~srichter]

[jira] [Commented] (FLINK-32681) RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailure unstablie

[ https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17749522#comment-17749522 ] Feifan Wang commented on FLINK-32681: - Hi [~srichter] , I'm also very interested in this problem. I

[jira] [Commented] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747855#comment-17747855 ] Feifan Wang commented on FLINK-25322: - {quote}One option is that checkpoints before state

[jira] [Commented] (FLINK-32664) TableSourceJsonPlanTest.testReuseSourceWithoutProjectionPushDown is failing

[ https://issues.apache.org/jira/browse/FLINK-32664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746776#comment-17746776 ] Feifan Wang commented on FLINK-32664: -

[jira] [Commented] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746750#comment-17746750 ] Feifan Wang commented on FLINK-25322: - Thanks for reply [~masteryhx] . {quote}Users have to check

[jira] [Commented] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740482#comment-17740482 ] Feifan Wang commented on FLINK-25322: - Thanks for reply [~pnowojski] , I'd love to write a flip, but

[jira] [Commented] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739364#comment-17739364 ] Feifan Wang commented on FLINK-25322: - Sorry for the late reply [~pnowojski] . {quote}just use the

[jira] [Commented] (FLINK-32478) SourceCoordinatorAlignmentTest.testAnnounceCombinedWatermarkWithoutStart fails

[ https://issues.apache.org/jira/browse/FLINK-32478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738373#comment-17738373 ] Feifan Wang commented on FLINK-32478: -

[jira] [Commented] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733588#comment-17733588 ] Feifan Wang commented on FLINK-25322: - Hi [~ym]  , [~ym]  ,  I saw that this issue has not been

[jira] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322 ] Feifan Wang deleted comment on FLINK-25322: - was (Author: feifan wang): Hi [~dwysakowicz] , [~ym] ,  I saw that this issue has not been progressed for a long time, I think it is very

[jira] [Commented] (FLINK-25322) Support no-claim mode in changelog state backend

[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733467#comment-17733467 ] Feifan Wang commented on FLINK-25322: - Hi [~dwysakowicz] , [~ym] ,  I saw that this issue has not

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

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17726933#comment-17726933 ] Feifan Wang commented on FLINK-29913: - Thanks for your information [~klion26] , I would like to add

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

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725624#comment-17725624 ] Feifan Wang commented on FLINK-29913: - Thanks [~roman] , I will prepare a pr. > Shared state would

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

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725470#comment-17725470 ] Feifan Wang edited comment on FLINK-29913 at 5/23/23 3:45 PM: -- Thanks for

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

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725470#comment-17725470 ] Feifan Wang commented on FLINK-29913: - Thanks for the clarification [~roman] !  {quote}Further,

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

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725387#comment-17725387 ] Feifan Wang commented on FLINK-29913: - One overhead I can see is that it will use more memory for

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

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725286#comment-17725286 ] Feifan Wang commented on FLINK-29913: - Sorry I didn't notice this ticket earlier so I submitted a

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

[ https://issues.apache.org/jira/browse/FLINK-32130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang closed FLINK-32130. --- Resolution: Duplicate duplicate to FLINK-29913 > previous checkpoint will be broke by the

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

[ https://issues.apache.org/jira/browse/FLINK-32130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725250#comment-17725250 ] Feifan Wang commented on FLINK-32130: - Sorry [~roman] , I didn't notice FLINK-29913 earlier, this

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

[ https://issues.apache.org/jira/browse/FLINK-32141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32141: Description: FLINK-29095 added some log to SharedStateRegistry for trouble shooting. Among them,

[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] [Comment Edited] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

[ https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724325#comment-17724325 ] Feifan Wang edited comment on FLINK-31743 at 5/19/23 3:41 PM: -- Thanks for

[jira] [Comment Edited] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

[ https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724325#comment-17724325 ] Feifan Wang edited comment on FLINK-31743 at 5/19/23 3:40 PM: -- Thank for

[jira] [Commented] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

[ https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724325#comment-17724325 ] Feifan Wang commented on FLINK-31743: - Thank for reminding, I created a new ticket, can you assign

[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] [Updated] (FLINK-32130) previous checkpoint will be broke by the subsequent incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32130: Component/s: Runtime / Checkpointing > previous checkpoint will be broke by the subsequent

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

[ https://issues.apache.org/jira/browse/FLINK-32130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-32130: Description: Currently, _SharedStateRegistryImpl_ will discard old one while register new state

[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:

[jira] [Commented] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

[ https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720736#comment-17720736 ] Feifan Wang commented on FLINK-31743: - Thanks [~yunta] , I submit a new

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

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717003#comment-17717003 ] Feifan Wang commented on FLINK-31139: - Thanks [~roman] , remember to re-run failed stages for 1.17.

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

[ https://issues.apache.org/jira/browse/FLINK-31900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716063#comment-17716063 ] Feifan Wang commented on FLINK-31900: - Thanks [~Weijie Guo] for review and merge the PR ! > Fix

[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

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714392#comment-17714392 ] Feifan Wang commented on FLINK-30863: - There are two known issues with dstl file cleanup: # local

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

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703441#comment-17703441 ] Feifan Wang edited comment on FLINK-31139 at 3/22/23 2:08 AM: -- Hi [~roman]

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

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703441#comment-17703441 ] Feifan Wang commented on FLINK-31139: - Hi [~roman] , should we merge this fix to release-1.16 &

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1770#comment-1770 ] Feifan Wang commented on FLINK-30863: - Hi [~Yanfei Lei] , sorry for the late reply, I agree to

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

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699928#comment-17699928 ] Feifan Wang commented on FLINK-31414: - Thanks for reply [~pnowojski] , sorry for the lack of clarity

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

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-31414: Description: Alignment timer task in alternating aligned checkpoint run as a future task in

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

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-31414: Description: Alignment timer task in alternating aligned checkpoint run as a future task in

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

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-31414: Description: Alignment timer task in alternating aligned checkpoint run as a future task in

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

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-31414: Description: Alignment timer task in alternating aligned checkpoint run as a future task in

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

[ https://issues.apache.org/jira/browse/FLINK-31414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-31414: Description: Alignment timer task in alternating aligned checkpoint run as a future task in

[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] [Closed] (FLINK-30792) clean up not uploaded state changes after materialization complete

[ https://issues.apache.org/jira/browse/FLINK-30792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang closed FLINK-30792. --- Fix Version/s: 1.17.0 1.16.2 Resolution: Duplicate > clean up not

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

[ https://issues.apache.org/jira/browse/FLINK-30792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686891#comment-17686891 ] Feifan Wang commented on FLINK-30792: - Thanks for your reply [~roman] , you are right, ref counting

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17683655#comment-17683655 ] Feifan Wang commented on FLINK-28440: - Hi [~ym] , [~roman] , I communicated with [~Yanfei Lei] 

[jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-28440: Attachment: image-2023-02-03-12-03-56-614.png > EventTimeWindowCheckpointingITCase failed with

[jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-28440: Attachment: image-2023-02-03-12-03-16-155.png > EventTimeWindowCheckpointingITCase failed with

[jira] [Comment Edited] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682677#comment-17682677 ] Feifan Wang edited comment on FLINK-28440 at 2/2/23 2:54 AM: - Hi [~Yanfei

[jira] [Comment Edited] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682912#comment-17682912 ] Feifan Wang edited comment on FLINK-28440 at 2/2/23 2:53 AM: - The updated

[jira] [Comment Edited] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682912#comment-17682912 ] Feifan Wang edited comment on FLINK-28440 at 2/1/23 11:34 AM: -- The updated

[jira] [Comment Edited] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682912#comment-17682912 ] Feifan Wang edited comment on FLINK-28440 at 2/1/23 8:59 AM: - The updated

[jira] [Comment Edited] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682912#comment-17682912 ] Feifan Wang edited comment on FLINK-28440 at 2/1/23 8:48 AM: - The updated

[jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-28440: Attachment: image-2023-02-01-16-47-23-756.png > EventTimeWindowCheckpointingITCase failed with

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682912#comment-17682912 ] Feifan Wang commented on FLINK-28440: - The updated

[jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-28440: Attachment: image-2023-02-01-16-46-19-254.png > EventTimeWindowCheckpointingITCase failed with

[jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-28440: Attachment: (was: image-2023-02-01-16-46-19-254.png) > EventTimeWindowCheckpointingITCase

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682896#comment-17682896 ] Feifan Wang commented on FLINK-28440: - [~Yanfei Lei] , Thank you for your reminder, the previous

[jira] [Comment Edited] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682677#comment-17682677 ] Feifan Wang edited comment on FLINK-28440 at 1/31/23 6:04 PM: -- Hi [~Yanfei

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682677#comment-17682677 ] Feifan Wang commented on FLINK-28440: - Hi [~Yanfei Lei] ,[~ym] ,[~roman] , We also encountered the

[jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-28440: Attachment: image-2023-02-01-01-19-12-182.png > EventTimeWindowCheckpointingITCase failed with

  1   2   3   4   >