[
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
[
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
> --
[
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
> ---
[
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:
[
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
[
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
>
>
>
[
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
> --
>
>
[
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
>
[
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.
[
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:
-
[
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:
-
[
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:
-
[
https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818230#comment-17818230
]
Yanfei Lei commented on FLINK-34448:
>From the watchdog:
{code:java}
Feb 16 02:20:16
[
https://issues.apache.org/jira/browse/FLINK-34455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819527#comment-17819527
]
Yanfei Lei commented on FLINK-34455:
merged 80090c7 into master.
> Move RestoreMode
[
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
> ---
[
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:
[
https://issues.apache.org/jira/browse/FLINK-34483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824683#comment-17824683
]
Yanfei Lei commented on FLINK-34483:
Merged 1d8cbe9 into master.
> Improve the docu
[
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'
> ---
[
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
> 'state.checkpoi
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: Tec
[
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 changelo
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-34624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825503#comment-17825503
]
Yanfei Lei commented on FLINK-34624:
Merged via 94b55d1.
> Enable local recovery in
[
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
> -
>
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
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-34581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827331#comment-17827331
]
Yanfei Lei commented on FLINK-34581:
Hi [~henning], it looks like it's caused by Jav
[
https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779106#comment-17779106
]
Yanfei Lei commented on FLINK-33341:
Hi [~srichter]
IIUC, only subtasks that are as
[
https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17793246#comment-17793246
]
Yanfei Lei commented on FLINK-8:
[~mayuehappy]/[~pnowojski] Some updates:
I fi
[
https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798802#comment-17798802
]
Yanfei Lei commented on FLINK-33863:
Is it because once the file stream has reached
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798802#comment-17798802
]
Yanfei Lei edited comment on FLINK-33863 at 12/20/23 3:18 AM:
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800702#comment-17800702
]
Yanfei Lei commented on FLINK-33863:
Merged via
[d415d93bbf9620ba985136469107edd8c6
[
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
>
>
>
[
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
>
[
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
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-34667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828573#comment-17828573
]
Yanfei Lei commented on FLINK-34667:
Merged via 501de48
> Changelog state backend s
[
https://issues.apache.org/jira/browse/FLINK-34668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831130#comment-17831130
]
Yanfei Lei commented on FLINK-34668:
Merged via 05b27be
> Report State handle of fi
[
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
> -
[
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
> -
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: Fl
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 Typ
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
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
[
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
[
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
>
[
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
>
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
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:
[
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
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
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
[
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
[
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
>
[
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
[
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
[
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
[
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
[
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
>
[
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
[
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
> ---
[
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
[
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
[
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
> ---
[
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
> ---
[
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
> -
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
[
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
> --
[
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
> ---
[
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
>
[
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
[
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
[
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
[
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
[
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:
-
[
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
> -
[
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
> --
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
[
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
> -
>
>
[
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
[
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
[
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
[
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
> -
[
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
[
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
>
[
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
[
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
[
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
[
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
>
[
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
[
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
[
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
>
[
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
[
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
>
[
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
>
[
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/
[
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
[
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
[
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
> ---
1 - 100 of 497 matches
Mail list logo
