[jira] [Created] (FLINK-35405) Add buffer size/in-flight records metrics for AsyncExecutionController

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

[jira] [Resolved] (FLINK-35030) Introduce Epoch Manager for async execution

[ https://issues.apache.org/jira/browse/FLINK-35030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35030. Resolution: Resolved > Introduce Epoch Manager for async execution >

[jira] [Commented] (FLINK-35030) Introduce Epoch Manager for async execution

[ https://issues.apache.org/jira/browse/FLINK-35030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848041#comment-17848041 ] Yanfei Lei commented on FLINK-35030: Merged into master via f1ecb9e > Introduce Epoch Manager for

[jira] [Comment Edited] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE

[ https://issues.apache.org/jira/browse/FLINK-35382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848030#comment-17848030 ] Yanfei Lei edited comment on FLINK-35382 at 5/21/24 2:35 AM: - Merged into

[jira] [Resolved] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE

[ https://issues.apache.org/jira/browse/FLINK-35382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35382. Assignee: Jinzhong Li Resolution: Fixed > ChangelogCompatibilityITCase.testRestore fails

[jira] [Commented] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE

[ https://issues.apache.org/jira/browse/FLINK-35382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848030#comment-17848030 ] Yanfei Lei commented on FLINK-35382: Merged into master via 26b149a. >

[jira] [Assigned] (FLINK-35049) Implement List/Map Async State API for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35049: -- Assignee: Yanfei Lei > Implement List/Map Async State API for ForStStateBackend >

[jira] [Commented] (FLINK-32082) Documentation of checkpoint file-merging

[ https://issues.apache.org/jira/browse/FLINK-32082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846859#comment-17846859 ] Yanfei Lei commented on FLINK-32082: Merged into master via a8cf2ba > Documentation of checkpoint

[jira] [Resolved] (FLINK-32082) Documentation of checkpoint file-merging

[ https://issues.apache.org/jira/browse/FLINK-32082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-32082. Resolution: Resolved > Documentation of checkpoint file-merging >

[jira] [Commented] (FLINK-32092) Integrate snapshot file-merging with existing IT cases

[ https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846784#comment-17846784 ] Yanfei Lei commented on FLINK-32092: Merged into master via b87ead7 > Integrate snapshot

[jira] [Resolved] (FLINK-32092) Integrate snapshot file-merging with existing IT cases

[ https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-32092. Resolution: Resolved > Integrate snapshot file-merging with existing IT cases >

[jira] [Resolved] (FLINK-32087) Space amplification statistics of file merging

[ https://issues.apache.org/jira/browse/FLINK-32087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-32087. Resolution: Fixed Merged into master via 9a5a99b > Space amplification statistics of file

[jira] [Closed] (FLINK-32443) Translate "State Processor API" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-32443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-32443. -- > Translate "State Processor API" page into Chinese > - >

[jira] [Resolved] (FLINK-32443) Translate "State Processor API" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-32443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-32443. Resolution: Resolved Merged into master via 26817092 > Translate "State Processor API" page into

[jira] [Assigned] (FLINK-32092) Integrate snapshot file-merging with existing IT cases

[ https://issues.apache.org/jira/browse/FLINK-32092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-32092: -- Assignee: Yanfei Lei (was: Rui Xia) > Integrate snapshot file-merging with existing IT

[jira] [Assigned] (FLINK-35029) Store timer in JVM heap when async execution enabled

[ https://issues.apache.org/jira/browse/FLINK-35029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35029: -- Assignee: Yanfei Lei > Store timer in JVM heap when async execution enabled >

[jira] [Resolved] (FLINK-32084) Migrate current file merging of channel state into the file merging framework

[ https://issues.apache.org/jira/browse/FLINK-32084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-32084. Resolution: Resolved > Migrate current file merging of channel state into the file merging

[jira] [Commented] (FLINK-32084) Migrate current file merging of channel state into the file merging framework

[ https://issues.apache.org/jira/browse/FLINK-32084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844896#comment-17844896 ] Yanfei Lei commented on FLINK-32084: Merged into master via 4fe66e0 > Migrate current file merging

[jira] [Commented] (FLINK-35158) Error handling in StateFuture's callback

[ https://issues.apache.org/jira/browse/FLINK-35158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844638#comment-17844638 ] Yanfei Lei commented on FLINK-35158: pr [24698|https://github.com/apache/flink/pull/24698] closed

[jira] [Resolved] (FLINK-35158) Error handling in StateFuture's callback

[ https://issues.apache.org/jira/browse/FLINK-35158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35158. Resolution: Resolved > Error handling in StateFuture's callback >

[jira] [Assigned] (FLINK-35030) Introduce Epoch Manager for async execution

[ https://issues.apache.org/jira/browse/FLINK-35030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35030: -- Assignee: Yanfei Lei > Introduce Epoch Manager for async execution >

[jira] [Updated] (FLINK-35030) Introduce Epoch Manager for async execution

[ https://issues.apache.org/jira/browse/FLINK-35030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-35030: --- Summary: Introduce Epoch Manager for async execution (was: Introduce Epoch Manager for under

[jira] [Resolved] (FLINK-35026) Introduce async execution configurations

[ https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35026. Resolution: Resolved > Introduce async execution configurations >

[jira] [Commented] (FLINK-35026) Introduce async execution configurations

[ https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841182#comment-17841182 ] Yanfei Lei commented on FLINK-35026: Merged into master via 713c30f..3ff2ba4  > Introduce async

[jira] [Commented] (FLINK-35178) Checkpoint CLAIM mode does not fully control snapshot ownership

[ https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841029#comment-17841029 ] Yanfei Lei commented on FLINK-35178: [~elon]  > the result was the same?   Does it mean that

[jira] [Comment Edited] (FLINK-35030) Introduce Epoch Manager for under async execution

[ https://issues.apache.org/jira/browse/FLINK-35030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840276#comment-17840276 ] Yanfei Lei edited comment on FLINK-35030 at 4/24/24 3:48 AM: - [~yunfengzhou] 

[jira] [Commented] (FLINK-35030) Introduce Epoch Manager for under async execution

[ https://issues.apache.org/jira/browse/FLINK-35030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840276#comment-17840276 ] Yanfei Lei commented on FLINK-35030: [~yunfengzhou]  > Thus shall we modify the scope of this

[jira] [Updated] (FLINK-35030) Introduce Epoch Manager for under async execution

[ https://issues.apache.org/jira/browse/FLINK-35030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-35030: --- Summary: Introduce Epoch Manager for under async execution (was: Introduce Epoch Manager for

[jira] [Commented] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController

[ https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839662#comment-17839662 ] Yanfei Lei commented on FLINK-35027: Merged into master via 9336760 > Implement checkpoint drain in

[jira] [Commented] (FLINK-35028) Timer firing under async execution model

[ https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839659#comment-17839659 ] Yanfei Lei commented on FLINK-35028: Merged into master via 0b2e988 > Timer firing under async

[jira] [Resolved] (FLINK-35028) Timer firing under async execution model

[ https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35028. Resolution: Resolved > Timer firing under async execution model >

[jira] [Assigned] (FLINK-35158) Error handling in StateFuture's callback

[ https://issues.apache.org/jira/browse/FLINK-35158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35158: -- Assignee: Yanfei Lei > Error handling in StateFuture's callback >

[jira] [Resolved] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController

[ https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35027. Resolution: Resolved > Implement checkpoint drain in AsyncExecutionController >

[jira] [Created] (FLINK-35158) Error handling in StateFuture's callback

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

[jira] [Assigned] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController

[ https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35027: -- Assignee: Yanfei Lei > Implement checkpoint drain in AsyncExecutionController >

[jira] [Assigned] (FLINK-35026) Introduce async execution configurations

[ https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35026: -- Assignee: Yanfei Lei > Introduce async execution configurations >

[jira] [Assigned] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35025: -- Assignee: Zakelly Lan > Wire AsyncExecutionController to AbstractStreamOperator >

[jira] [Updated] (FLINK-35031) Latency marker emitting under async execution model

[ https://issues.apache.org/jira/browse/FLINK-35031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-35031: --- Summary: Latency marker emitting under async execution model (was: Event timer firing under async

[jira] [Commented] (FLINK-35031) Event timer firing under async execution model

[ https://issues.apache.org/jira/browse/FLINK-35031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838022#comment-17838022 ] Yanfei Lei commented on FLINK-35031: [~yunfengzhou] At first I planned to implement event timer and

[jira] [Assigned] (FLINK-35028) Timer firing under async execution model

[ https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35028: -- Assignee: Yanfei Lei > Timer firing under async execution model >

[jira] [Updated] (FLINK-35028) Timer firing under async execution model

[ https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-35028: --- Summary: Timer firing under async execution model (was: Processing timer firing under async

[jira] [Resolved] (FLINK-32440) Introduce file merging configuration

[ https://issues.apache.org/jira/browse/FLINK-32440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-32440. Resolution: Resolved > Introduce file merging configuration >

[jira] [Commented] (FLINK-32440) Introduce file merging configuration

[ https://issues.apache.org/jira/browse/FLINK-32440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837085#comment-17837085 ] Yanfei Lei commented on FLINK-32440: Merged c601c70 into master. > Introduce file merging

[jira] [Commented] (FLINK-35024) Implement record order preservation and buffering of AsyncExecutionController

[ https://issues.apache.org/jira/browse/FLINK-35024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837083#comment-17837083 ] Yanfei Lei commented on FLINK-35024: Merged 6d139a1 into master  > Implement record order

[jira] [Resolved] (FLINK-35024) Implement record order preservation and buffering of AsyncExecutionController

[ https://issues.apache.org/jira/browse/FLINK-35024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35024. Resolution: Resolved > Implement record order preservation and buffering of

[jira] [Resolved] (FLINK-34986) Basic framework of async execution for state

[ https://issues.apache.org/jira/browse/FLINK-34986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-34986. Resolution: Resolved > Basic framework of async execution for state >

[jira] [Assigned] (FLINK-35024) Implement record order preservation and buffering of AsyncExecutionController

[ https://issues.apache.org/jira/browse/FLINK-35024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35024: -- Assignee: Yanfei Lei > Implement record order preservation and buffering of

[jira] [Commented] (FLINK-34986) Basic framework of async execution for state

[ https://issues.apache.org/jira/browse/FLINK-34986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835956#comment-17835956 ] Yanfei Lei commented on FLINK-34986: Merged 60c771b...ec2a140 into master. > Basic framework of

[jira] [Created] (FLINK-35031) Event timer firing under async execution model

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:

[jira] [Created] (FLINK-35030) Introduce Epoch Manager for watermark under async execution

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

[jira] [Updated] (FLINK-35026) Introduce async execution configurations

[ https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-35026: --- Summary: Introduce async execution configurations (was: Introduce async-state configurations) >

[jira] [Created] (FLINK-35029) Store timer in JVM heap when async execution enabled

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:

[jira] [Created] (FLINK-35028) Processing timer firing under async execution model

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:

[jira] [Updated] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController

[ https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-35027: --- Component/s: Runtime / Checkpointing > Implement checkpoint drain in AsyncExecutionController >

[jira] [Updated] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-35025: --- Component/s: Runtime / Task > Wire AsyncExecutionController to AbstractStreamOperator >

[jira] [Updated] (FLINK-35026) Introduce async-state configurations

[ https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-35026: --- Component/s: Runtime / Configuration Runtime / Task > Introduce async-state

[jira] [Created] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController

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

[jira] [Created] (FLINK-35026) Introduce async-state configurations

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

[jira] [Created] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator

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

[jira] [Created] (FLINK-35024) Implement record order preservation and buffering of AsyncExecutionController

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:

[jira] [Assigned] (FLINK-34973) FLIP-425: Asynchronous Execution Model

[ https://issues.apache.org/jira/browse/FLINK-34973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-34973: -- Assignee: Yanfei Lei > FLIP-425: Asynchronous Execution Model >

[jira] [Closed] (FLINK-34668) Report State handle of file merging directory to JM

[ https://issues.apache.org/jira/browse/FLINK-34668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-34668. -- Resolution: Resolved > Report State handle of file merging directory to JM >

[jira] [Commented] (FLINK-34668) Report State handle of file merging directory to JM

[ https://issues.apache.org/jira/browse/FLINK-34668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831130#comment-17831130 ] Yanfei Lei commented on FLINK-34668: Merged via 05b27be > Report State handle of file merging

[jira] [Commented] (FLINK-34667) Changelog state backend support local rescaling

[ https://issues.apache.org/jira/browse/FLINK-34667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828573#comment-17828573 ] Yanfei Lei commented on FLINK-34667: Merged via 501de48 > Changelog state backend support local

[jira] [Closed] (FLINK-34667) Changelog state backend support local rescaling

[ https://issues.apache.org/jira/browse/FLINK-34667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-34667. -- > Changelog state backend support local rescaling > --- > >

[jira] [Resolved] (FLINK-34667) Changelog state backend support local rescaling

[ https://issues.apache.org/jira/browse/FLINK-34667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-34667. Resolution: Fixed > Changelog state backend support local rescaling >

[jira] [Commented] (FLINK-34581) streaming code throws java.lang.reflect.InaccessibleObjectException

[ https://issues.apache.org/jira/browse/FLINK-34581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827331#comment-17827331 ] Yanfei Lei commented on FLINK-34581: Hi [~henning], it looks like it's caused by Java setting, have

[jira] [Assigned] (FLINK-34667) Changelog state backend support local rescaling

[ https://issues.apache.org/jira/browse/FLINK-34667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-34667: -- Assignee: Yanfei Lei > Changelog state backend support local rescaling >

[jira] [Created] (FLINK-34667) Changelog state backend support local rescaling

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

[jira] [Closed] (FLINK-34624) Enable local recovery in ChangelogRescalingITCase

[ https://issues.apache.org/jira/browse/FLINK-34624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-34624. -- > Enable local recovery in ChangelogRescalingITCase > - >

[jira] [Resolved] (FLINK-34624) Enable local recovery in ChangelogRescalingITCase

[ https://issues.apache.org/jira/browse/FLINK-34624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-34624. Resolution: Fixed > Enable local recovery in ChangelogRescalingITCase >

[jira] [Commented] (FLINK-34624) Enable local recovery in ChangelogRescalingITCase

[ https://issues.apache.org/jira/browse/FLINK-34624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825503#comment-17825503 ] Yanfei Lei commented on FLINK-34624: Merged via 94b55d1. > Enable local recovery in

[jira] [Updated] (FLINK-34624) Enable local recovery in ChangelogRescalingITCase

[ https://issues.apache.org/jira/browse/FLINK-34624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-34624: --- Description: Enable local recovery in ChangelogRescalingITCase, since the local recovery of

[jira] [Created] (FLINK-34624) Enable local recovery in ChangelogRescalingITCase

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:

[jira] [Resolved] (FLINK-34483) Improve the documentation of 'state.checkpoints.dir' and 'state.checkpoint-storage'

[ https://issues.apache.org/jira/browse/FLINK-34483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-34483. Resolution: Resolved > Improve the documentation of 'state.checkpoints.dir' and >

[jira] [Closed] (FLINK-34483) Improve the documentation of 'state.checkpoints.dir' and 'state.checkpoint-storage'

[ https://issues.apache.org/jira/browse/FLINK-34483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-34483. -- > Improve the documentation of 'state.checkpoints.dir' and > 'state.checkpoint-storage' >

[jira] [Commented] (FLINK-34483) Improve the documentation of 'state.checkpoints.dir' and 'state.checkpoint-storage'

[ https://issues.apache.org/jira/browse/FLINK-34483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17824683#comment-17824683 ] Yanfei Lei commented on FLINK-34483: Merged 1d8cbe9 into master. > Improve the documentation of

[jira] [Updated] (FLINK-34483) Improve the documentation of 'state.checkpoints.dir' and 'state.checkpoint-storage'

[ https://issues.apache.org/jira/browse/FLINK-34483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-34483: --- Summary: Improve the documentation of 'state.checkpoints.dir' and 'state.checkpoint-storage' (was:

[jira] [Resolved] (FLINK-34455) Move RestoreMode from flink-runtime to flink-core

[ https://issues.apache.org/jira/browse/FLINK-34455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-34455. Resolution: Resolved > Move RestoreMode from flink-runtime to flink-core >

[jira] [Commented] (FLINK-34455) Move RestoreMode from flink-runtime to flink-core

[ https://issues.apache.org/jira/browse/FLINK-34455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17819527#comment-17819527 ] Yanfei Lei commented on FLINK-34455: merged 80090c7 into master. > Move RestoreMode from

[jira] [Commented] (FLINK-34448) ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code

[ https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818230#comment-17818230 ] Yanfei Lei commented on FLINK-34448: >From the watchdog: {code:java} Feb 16 02:20:16 02:20:16.815

[jira] [Closed] (FLINK-33863) Compressed Operator state restore failed

[ https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-33863. -- > Compressed Operator state restore failed > > >

[jira] [Commented] (FLINK-33863) Compressed Operator state restore failed

[ https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800702#comment-17800702 ] Yanfei Lei commented on FLINK-33863: Merged via

[jira] [Resolved] (FLINK-33863) Compressed Operator state restore failed

[ https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-33863. Fix Version/s: 1.19.0 Resolution: Fixed > Compressed Operator state restore failed >

[jira] [Comment Edited] (FLINK-33863) Compressed Operator state restore failed

[ https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798802#comment-17798802 ] Yanfei Lei edited comment on FLINK-33863 at 12/20/23 3:18 AM: -- Is it

[jira] [Assigned] (FLINK-33863) Compressed Operator state restore failed

[ https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-33863: -- Assignee: Ruibin Xing > Compressed Operator state restore failed >

[jira] [Commented] (FLINK-33863) Compressed Operator state restore failed

[ https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798802#comment-17798802 ] Yanfei Lei commented on FLINK-33863: Is it because once the file stream has reached EOF, we can‘t

[jira] [Commented] (FLINK-33338) Bump FRocksDB version

[ https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17793246#comment-17793246 ] Yanfei Lei commented on FLINK-8: [~mayuehappy]/[~pnowojski]  Some updates: I first released a

[jira] [Commented] (FLINK-33341) Use available local state for rescaling

[ https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779106#comment-17779106 ] Yanfei Lei commented on FLINK-33341: Hi [~srichter] IIUC, only subtasks that are assigned to the

[jira] [Closed] (FLINK-32072) Create and wire FileMergingSnapshotManager with TaskManagerServices

[ https://issues.apache.org/jira/browse/FLINK-32072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-32072. -- > Create and wire FileMergingSnapshotManager with TaskManagerServices >

[jira] [Resolved] (FLINK-32072) Create and wire FileMergingSnapshotManager with TaskManagerServices

[ https://issues.apache.org/jira/browse/FLINK-32072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-32072. Fix Version/s: 1.19.0 (was: 1.18.0) Resolution: Fixed > Create and

[jira] [Commented] (FLINK-32072) Create and wire FileMergingSnapshotManager with TaskManagerServices

[ https://issues.apache.org/jira/browse/FLINK-32072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773884#comment-17773884 ] Yanfei Lei commented on FLINK-32072: Merged into master via 1112582fd136df47c6d356d6f6ad3946ad1e56d5

[jira] [Commented] (FLINK-33161) [benchmark] Java17 profile for benchmarks

[ https://issues.apache.org/jira/browse/FLINK-33161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773076#comment-17773076 ] Yanfei Lei commented on FLINK-33161: Merged via 60e3522d3920391ae75234b67af7d3c774f4c7b3 >

[jira] [Closed] (FLINK-33161) [benchmark] Java17 profile for benchmarks

[ https://issues.apache.org/jira/browse/FLINK-33161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-33161. -- > [benchmark] Java17 profile for benchmarks > - > >

[jira] [Resolved] (FLINK-33161) [benchmark] Java17 profile for benchmarks

[ https://issues.apache.org/jira/browse/FLINK-33161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-33161. Resolution: Fixed > [benchmark] Java17 profile for benchmarks >

[jira] [Assigned] (FLINK-33127) HeapKeyedStateBackend: use buffered I/O to speed up local recovery

[ https://issues.apache.org/jira/browse/FLINK-33127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-33127: -- Assignee: Yangyang ZHANG > HeapKeyedStateBackend: use buffered I/O to speed up local

[jira] [Closed] (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 ] Yanfei Lei closed FLINK-32769. -- > PeriodicMaterializationManager pass descriptionFormat with invalid > placeholder to

[jira] [Resolved] (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 ] Yanfei Lei resolved FLINK-32769. Fix Version/s: 1.19.0 Assignee: Feifan Wang Resolution: Fixed >

[jira] [Commented] (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:comment-tabpanel=17765894#comment-17765894 ] Yanfei Lei commented on FLINK-32769: Merged via 13469792821ee1e9d2171a28a071cc986626316e  >

[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=17759876#comment-17759876 ] Yanfei Lei commented on FLINK-28440: [~renqs] Sorry for the late reply, I found that the recent

  1   2   3   4   >