[jira] [Resolved] (FLINK-36373) Support dispatch state requests in task thread

[ https://issues.apache.org/jira/browse/FLINK-36373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-36373. Resolution: Resolved Merged into master via 73a02855 > Support dispatch state requests in task th

[jira] [Updated] (FLINK-36373) Support dispatch state requests in task thread

[ https://issues.apache.org/jira/browse/FLINK-36373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-36373: --- Summary: Support dispatch state requests in task thread (was: Support distribute state requests in

[jira] [Assigned] (FLINK-36373) Support distribute state requests in task thread

[ https://issues.apache.org/jira/browse/FLINK-36373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-36373: -- Assignee: Yanfei Lei > Support distribute state requests in task thread > ---

[jira] [Created] (FLINK-36373) Support distribute state requests in task thread

Yanfei Lei created FLINK-36373: -- Summary: Support distribute state requests in task thread Key: FLINK-36373 URL: https://issues.apache.org/jira/browse/FLINK-36373 Project: Flink Issue Type: Sub-

[jira] [Resolved] (FLINK-36331) Support multiGet for forstdb

[ https://issues.apache.org/jira/browse/FLINK-36331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-36331. Resolution: Resolved > Support multiGet for forstdb > > >

[jira] [Updated] (FLINK-36331) Support multiGet for forstdb

[ https://issues.apache.org/jira/browse/FLINK-36331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-36331: --- Summary: Support multiGet for forstdb (was: Support multiGet when DB all in local) > Support multi

[jira] [Commented] (FLINK-36331) Support multiGet when DB all in local

[ https://issues.apache.org/jira/browse/FLINK-36331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884600#comment-17884600 ] Yanfei Lei commented on FLINK-36331: Merged into master via f33abff > Support multi

[jira] [Resolved] (FLINK-36321) Execute read/write state request in different executor

[ https://issues.apache.org/jira/browse/FLINK-36321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-36321. Assignee: Yanfei Lei Resolution: Fixed Merged into master via 1d1bf5c8f > Execute read/writ

[jira] [Resolved] (FLINK-36314) Support state V1 interface

[ https://issues.apache.org/jira/browse/FLINK-36314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-36314. Assignee: Yanfei Lei Resolution: Resolved > Support state V1 interface > ---

[jira] [Commented] (FLINK-36314) Support state V1 interface

[ https://issues.apache.org/jira/browse/FLINK-36314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883196#comment-17883196 ] Yanfei Lei commented on FLINK-36314: Merged into master via 1ba8900 > Support state

[jira] [Created] (FLINK-36331) Support multiGet when DB all in local

Yanfei Lei created FLINK-36331: -- Summary: Support multiGet when DB all in local Key: FLINK-36331 URL: https://issues.apache.org/jira/browse/FLINK-36331 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36321) Execute read/write state request in different executor

Yanfei Lei created FLINK-36321: -- Summary: Execute read/write state request in different executor Key: FLINK-36321 URL: https://issues.apache.org/jira/browse/FLINK-36321 Project: Flink Issue Type

[jira] [Created] (FLINK-36314) Support state V1 interface

Yanfei Lei created FLINK-36314: -- Summary: Support state V1 interface Key: FLINK-36314 URL: https://issues.apache.org/jira/browse/FLINK-36314 Project: Flink Issue Type: Sub-task Repor

[jira] [Resolved] (FLINK-35927) Make ForStFlinkFileSystem save misc file in local filesystem

[ https://issues.apache.org/jira/browse/FLINK-35927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35927. Resolution: Resolved > Make ForStFlinkFileSystem save misc file in local filesystem >

[jira] [Commented] (FLINK-35667) Implement Reducing Async State API for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881737#comment-17881737 ] Yanfei Lei commented on FLINK-35667: Merged into master via d8b3243 > Implement Red

[jira] [Resolved] (FLINK-35667) Implement Reducing Async State API for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35667. Assignee: Yanfei Lei Resolution: Resolved > Implement Reducing Async State API for ForStStat

[jira] [Commented] (FLINK-35927) Make ForStFlinkFileSystem save misc file in local filesystem

[ https://issues.apache.org/jira/browse/FLINK-35927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881736#comment-17881736 ] Yanfei Lei commented on FLINK-35927: Merged into master via f520674 > Make ForStFli

[jira] [Assigned] (FLINK-36243) Store namespace in ContextKey and state request

[ https://issues.apache.org/jira/browse/FLINK-36243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-36243: -- Assignee: Yanfei Lei > Store namespace in ContextKey and state request >

[jira] [Commented] (FLINK-36243) Store namespace in ContextKey and state request

[ https://issues.apache.org/jira/browse/FLINK-36243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880949#comment-17880949 ] Yanfei Lei commented on FLINK-36243: Merged into master via 25969c9 > Store namespa

[jira] [Resolved] (FLINK-36243) Store namespace in ContextKey and state request

[ https://issues.apache.org/jira/browse/FLINK-36243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-36243. Resolution: Resolved > Store namespace in ContextKey and state request > -

[jira] [Updated] (FLINK-36243) Store namespace in ContextKey and state request

[ https://issues.apache.org/jira/browse/FLINK-36243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-36243: --- Summary: Store namespace in ContextKey and state request (was: Store namespace in ContextKey) > St

[jira] [Updated] (FLINK-35927) Make ForStFlinkFileSystem save misc file in local filesystem

[ https://issues.apache.org/jira/browse/FLINK-35927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-35927: --- Summary: Make ForStFlinkFileSystem save misc file in local filesystem (was: Support closing ForSt m

[jira] [Commented] (FLINK-35049) Implement Map Async State API for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880488#comment-17880488 ] Yanfei Lei commented on FLINK-35049: Merged into master via 277706d > Implement Map

[jira] [Updated] (FLINK-36243) Store namespace in ContextKey

[ https://issues.apache.org/jira/browse/FLINK-36243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-36243: --- Fix Version/s: 2.0-preview > Store namespace in ContextKey > - > >

[jira] [Created] (FLINK-36243) Store namespace in ContextKey

Yanfei Lei created FLINK-36243: -- Summary: Store namespace in ContextKey Key: FLINK-36243 URL: https://issues.apache.org/jira/browse/FLINK-36243 Project: Flink Issue Type: Sub-task Comp

[jira] [Resolved] (FLINK-34510) Flink 2.0: Rename RestoreMode to RecoveryClaimMode

[ https://issues.apache.org/jira/browse/FLINK-34510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-34510. Resolution: Done > Flink 2.0: Rename RestoreMode to RecoveryClaimMode > --

[jira] [Resolved] (FLINK-35049) Implement 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 resolved FLINK-35049. Resolution: Done > Implement Map Async State API for ForStStateBackend > -

[jira] [Comment Edited] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864534#comment-17864534 ] Yanfei Lei edited comment on FLINK-35624 at 7/10/24 8:37 AM: -

[jira] [Comment Edited] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864534#comment-17864534 ] Yanfei Lei edited comment on FLINK-35624 at 7/10/24 8:33 AM: -

[jira] [Comment Edited] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864534#comment-17864534 ] Yanfei Lei edited comment on FLINK-35624 at 7/10/24 8:14 AM: -

[jira] [Commented] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864534#comment-17864534 ] Yanfei Lei commented on FLINK-35624: I tested some scenarios after [~zakelly]'s fix.

[jira] [Closed] (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 closed FLINK-32084. -- > Migrate current file merging of channel state into the file merging framework >

[jira] [Closed] (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 closed FLINK-32087. -- > Space amplification statistics of file merging > -- > >

[jira] [Closed] (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 closed FLINK-32082. -- > Documentation of checkpoint file-merging > > >

[jira] [Closed] (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 closed FLINK-32440. -- > Introduce file merging configuration > > > Key: FLI

[jira] [Closed] (FLINK-32091) Add necessary metrics for file-merging

[ https://issues.apache.org/jira/browse/FLINK-32091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-32091. -- > Add necessary metrics for file-merging > -- > > Key:

[jira] [Closed] (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 closed FLINK-32092. -- > Integrate snapshot file-merging with existing IT cases > ---

[jira] [Resolved] (FLINK-32091) Add necessary metrics for file-merging

[ https://issues.apache.org/jira/browse/FLINK-32091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-32091. Resolution: Resolved > Add necessary metrics for file-merging > --

[jira] [Commented] (FLINK-32091) Add necessary metrics for file-merging

[ https://issues.apache.org/jira/browse/FLINK-32091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17855029#comment-17855029 ] Yanfei Lei commented on FLINK-32091: Merged into master via 5497868. > Add necessar

[jira] [Created] (FLINK-35495) The native metrics for column family are not reported

Yanfei Lei created FLINK-35495: -- Summary: The native metrics for column family are not reported Key: FLINK-35495 URL: https://issues.apache.org/jira/browse/FLINK-35495 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-35457) EventTimeWindowCheckpointingITCase fails on AZP as NPE

[ https://issues.apache.org/jira/browse/FLINK-35457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35457. Resolution: Fixed > EventTimeWindowCheckpointingITCase fails on AZP as NPE > -

[jira] [Assigned] (FLINK-35457) EventTimeWindowCheckpointingITCase fails on AZP as NPE

[ https://issues.apache.org/jira/browse/FLINK-35457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-35457: -- Assignee: Yanfei Lei > EventTimeWindowCheckpointingITCase fails on AZP as NPE > -

[jira] [Commented] (FLINK-35457) EventTimeWindowCheckpointingITCase fails on AZP as NPE

[ https://issues.apache.org/jira/browse/FLINK-35457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849864#comment-17849864 ] Yanfei Lei commented on FLINK-35457: Merged into master via 1e996b8 > EventTimeWind

[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&focusedCommentId=17848041#comment-17848041 ] Yanfei Lei commented on FLINK-35030: Merged into master via f1ecb9e > Introduce Epo

[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&focusedCommentId=17848030#comment-17848030 ] Yanfei Lei edited comment on FLINK-35382 at 5/21/24 2:35 AM: -

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

[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&focusedCommentId=17848030#comment-17848030 ] Yanfei Lei commented on FLINK-35382: Merged into master via 26b149a. > ChangelogCom

[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&focusedCommentId=17846859#comment-17846859 ] Yanfei Lei commented on FLINK-32082: Merged into master via a8cf2ba > Documentation

[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&focusedCommentId=17846784#comment-17846784 ] Yanfei Lei commented on FLINK-32092: Merged into master via b87ead7 > Integrate sna

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

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

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

[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&focusedCommentId=17844896#comment-17844896 ] Yanfei Lei commented on FLINK-32084: Merged into master via 4fe66e0 > Migrate curre

[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&focusedCommentId=17844638#comment-17844638 ] Yanfei Lei commented on FLINK-35158: pr [24698|https://github.com/apache/flink/pull/

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

[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&focusedCommentId=17841182#comment-17841182 ] Yanfei Lei commented on FLINK-35026: Merged into master via 713c30f..3ff2ba4  > Int

[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&focusedCommentId=17841029#comment-17841029 ] Yanfei Lei commented on FLINK-35178: [~elon]  > the result was the same?   Does i

[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&focusedCommentId=17840276#comment-17840276 ] Yanfei Lei edited comment on FLINK-35030 at 4/24/24 3:48 AM: -

[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&focusedCommentId=17840276#comment-17840276 ] Yanfei Lei commented on FLINK-35030: [~yunfengzhou]  > Thus shall we modify the sco

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

[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&focusedCommentId=17839662#comment-17839662 ] Yanfei Lei commented on FLINK-35027: Merged into master via 9336760 > Implement che

[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&focusedCommentId=17839659#comment-17839659 ] Yanfei Lei commented on FLINK-35028: Merged into master via 0b2e988 > Timer firing

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

[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&focusedCommentId=17838022#comment-17838022 ] Yanfei Lei commented on FLINK-35031: [~yunfengzhou] At first I planned to implement

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

[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&focusedCommentId=17837085#comment-17837085 ] Yanfei Lei commented on FLINK-32440: Merged c601c70 into master. > Introduce file m

[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&focusedCommentId=17837083#comment-17837083 ] Yanfei Lei commented on FLINK-35024: Merged 6d139a1 into master  > Implement record

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

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

[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&focusedCommentId=17835956#comment-17835956 ] Yanfei Lei commented on FLINK-34986: Merged 60c771b...ec2a140 into master. > Basic

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

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

[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) > In

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

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

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

  1   2   3   4   >