[jira] [Commented] (FLINK-26490) Adjust the MaxParallelism or remove the MaxParallelism check when unnecessary.

2023-11-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785394#comment-17785394 ] Yuan Mei commented on FLINK-26490: -- Sorry to respond late. Just saw this ticket recentl

[jira] [Commented] (FLINK-32073) Implement file merging in snapshot

2024-01-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17809461#comment-17809461 ] Yuan Mei commented on FLINK-32073: -- merged commit  [{{f9f9299}}|https://github.com/apac

[jira] [Closed] (FLINK-32073) Implement file merging in snapshot

2024-01-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei closed FLINK-32073. Resolution: Done > Implement file merging in snapshot > -- > >

[jira] [Created] (FLINK-34984) Disaggregated State Storage and Management (Umbrella FLIP)

2024-04-01 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-34984: Summary: Disaggregated State Storage and Management (Umbrella FLIP) Key: FLINK-34984 URL: https://issues.apache.org/jira/browse/FLINK-34984 Project: Flink Issue Type

[jira] [Updated] (FLINK-34984) Disaggregated State Storage and Management (Umbrella FLIP)

2024-04-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-34984: - Description: The past decade has witnessed a dramatic shift in Flink's deployment mode, workload pattern

[jira] [Updated] (FLINK-34984) FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP)

2024-04-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-34984: - Description: The past decade has witnessed a dramatic shift in Flink's deployment mode, workload patter

[jira] [Updated] (FLINK-34984) FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP)

2024-04-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-34984: - Description: The past decade has witnessed a dramatic shift in Flink's deployment mode, workload patter

[jira] [Updated] (FLINK-34984) FLIP-423: Disaggregated State Storage and Management (Umbrella FLIP)

2024-04-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-34984: - Description: The past decade has witnessed a dramatic shift in Flink's deployment mode, workload patter

[jira] [Assigned] (FLINK-33052) codespeed server is down

2023-09-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-33052: Assignee: Yuan Mei (was: Yanfei Lei) > codespeed server is down > > >

[jira] [Commented] (FLINK-33052) codespeed server is down

2023-09-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764484#comment-17764484 ] Yuan Mei commented on FLINK-33052: -- Let me see whether i can get a new machine for this

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764484#comment-17764484 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 4:44 AM: --- Le

[jira] [Assigned] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-33052: Assignee: Zakelly Lan (was: Yuan Mei) > codespeed server is down > > >

[jira] [Commented] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764570#comment-17764570 ] Yuan Mei commented on FLINK-33052: -- [~pnowojski] We have the historical data backed up.

[jira] [Updated] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-33052: - Priority: Critical (was: Blocker) > codespeed server is down > > >

[jira] [Commented] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei commented on FLINK-33052: -- # I think this issue is very critical as you mentio

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:30 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:31 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:31 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:31 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:35 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:35 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:39 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:41 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 1:44 PM: --- He

[jira] [Comment Edited] (FLINK-33052) codespeed server is down

2023-09-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764675#comment-17764675 ] Yuan Mei edited comment on FLINK-33052 at 9/13/23 2:14 PM: --- He

[jira] [Updated] (FLINK-33052) codespeed and benchmark server is down

2023-10-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-33052: - Affects Version/s: 1.19.0 (was: 1.18.0) > codespeed and benchmark server is d

[jira] [Comment Edited] (FLINK-33052) codespeed and benchmark server is down

2023-10-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774779#comment-17774779 ] Yuan Mei edited comment on FLINK-33052 at 10/13/23 4:19 AM:

[jira] [Commented] (FLINK-33052) codespeed and benchmark server is down

2023-10-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774779#comment-17774779 ] Yuan Mei commented on FLINK-33052: -- As the pipeline has been running daily, and the rep

[jira] [Commented] (FLINK-17916) Provide API to separate KafkaShuffle's Producer and Consumer to different jobs

2023-10-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776099#comment-17776099 ] Yuan Mei commented on FLINK-17916: -- Yes, I think so. Thanks for reminding [~martijnviss

[jira] [Closed] (FLINK-17916) Provide API to separate KafkaShuffle's Producer and Consumer to different jobs

2023-10-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei closed FLINK-17916. Resolution: Won't Do > Provide API to separate KafkaShuffle's Producer and Consumer to different jobs > --

[jira] [Commented] (FLINK-20418) NPE in IteratorSourceReader

2020-11-30 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240617#comment-17240617 ] Yuan Mei commented on FLINK-20418: -- with the default setting, I get the same exception:

[jira] [Commented] (FLINK-20418) NPE in IteratorSourceReader

2020-11-30 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240621#comment-17240621 ] Yuan Mei commented on FLINK-20418: -- change the sleep time to 50, get the same error:  

[jira] [Commented] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-11-30 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei commented on FLINK-19249: -- The problem has been thoroughly explained in both F

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-11-30 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 7:56 AM:

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-11-30 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 7:57 AM:

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-12-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 8:19 AM:

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-12-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 9:56 AM:

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-12-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 9:56 AM:

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-12-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 9:57 AM:

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-12-01 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241327#comment-17241327 ] Yuan Mei edited comment on FLINK-19249 at 12/1/20, 9:59 AM:

[jira] [Commented] (FLINK-18113) Single Task Failure Recovery API Abstraction

2020-12-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245294#comment-17245294 ] Yuan Mei commented on FLINK-18113: -- Some thoughts here: Each shuffle mode may require

[jira] [Updated] (FLINK-18113) Single Task Failure Recovery API Abstraction

2020-12-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-18113: - Description: Overall, I would like to keep a track of discussion on API changes needed based on FLINK-1

[jira] [Updated] (FLINK-18113) Single Task Failure Recovery API Abstraction

2020-12-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-18113: - Parent: FLINK-18112 Issue Type: Sub-task (was: New Feature) > Single Task Failure Recovery API

[jira] [Commented] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

2020-12-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245644#comment-17245644 ] Yuan Mei commented on FLINK-17331: -- Hey, [~karmagyz]. I think the change would be safe

[jira] [Comment Edited] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

2020-12-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245644#comment-17245644 ] Yuan Mei edited comment on FLINK-17331 at 12/8/20, 3:39 AM:

[jira] [Commented] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2020-12-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245663#comment-17245663 ] Yuan Mei commented on FLINK-19249: -- A bit more implementation suggestions:   I would

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 4:26 AM: -

[jira] [Commented] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248736#comment-17248736 ] Yuan Mei commented on FLINK-18983: -- Hey [~liuyufei], thanks for reporting! just to conf

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 4:27 AM: -

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 4:28 AM: -

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 6:31 AM: -

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 6:31 AM: -

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 6:32 AM: -

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 6:32 AM: -

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-13 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 7:13 AM: -

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 10:06 AM:

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-14 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 10:06 AM:

[jira] [Commented] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251540#comment-17251540 ] Yuan Mei commented on FLINK-18983: -- Hey, [~liuyufei]. You are absolutely right: Having

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251540#comment-17251540 ] Yuan Mei edited comment on FLINK-18983 at 12/18/20, 6:40 AM: -

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251540#comment-17251540 ] Yuan Mei edited comment on FLINK-18983 at 12/18/20, 6:40 AM: -

[jira] [Updated] (FLINK-19693) Scheduler Change for Approximate Local Recovery to Restart Downstream of a Failed Task

2020-11-02 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-19693: - Description: Enables downstream failover for approximate local recovery. That says if a task fails, all

[jira] [Updated] (FLINK-19988) Make Approximate Local Recovery Compatible With Unaligned Checkpoint

2020-11-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-19988: - Description: This is a Jira ticket to track all potential issues that may cause incompatibility between 

[jira] [Updated] (FLINK-19988) Make Approximate Local Recovery Compatible With Unaligned Checkpoint

2020-11-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-19988: - Description: This is a Jira ticket to track all potential issues that may cause incompatibility between

[jira] [Updated] (FLINK-19988) Make Approximate Local Recovery Compatible With Unaligned Checkpoint

2020-11-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-19988: - Description: This is a Jira ticket to track all potential issues that may cause incompatibility between

[jira] [Updated] (FLINK-19988) Make Approximate Local Recovery Compatible With Unaligned Checkpoint

2020-11-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-19988: - Description: This is a Jira ticket to track all potential issues that may cause incompatibility between

[jira] [Updated] (FLINK-19988) Make Approximate Local Recovery Compatible With Unaligned Checkpoint

2020-11-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-19988: - Description: This is a Jira ticket to track all potential issues that may cause incompatibility between

[jira] [Created] (FLINK-19988) Make Approximate Local Recovery Compatible With Unaligned Checkpoint

2020-11-04 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-19988: Summary: Make Approximate Local Recovery Compatible With Unaligned Checkpoint Key: FLINK-19988 URL: https://issues.apache.org/jira/browse/FLINK-19988 Project: Flink

[jira] [Created] (FLINK-20048) Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy

2020-11-08 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-20048: Summary: Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy Key: FLINK-20048 URL: https://issues.apache.org/jira/browse/FLINK-20048 Project: Fl

[jira] [Updated] (FLINK-20048) Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy

2020-11-08 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-20048: - Description: in the case where approximate_failover is enabled, *only source task* is scheduled to be d

[jira] [Updated] (FLINK-20048) Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy

2020-11-08 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-20048: - Description: in the case where approximate_failover is enabled, *only source task* is scheduled to be d

[jira] [Commented] (FLINK-20048) Make Approximate Local Recovery Compatible With PipelinedRegionSchedulingStrategy

2020-11-08 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227996#comment-17227996 ] Yuan Mei commented on FLINK-20048: -- This should have higher priority since it blocks en

[jira] [Commented] (FLINK-19693) Scheduler Change for Approximate Local Recovery to Restart Downstream of a Failed Task

2020-11-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17228517#comment-17228517 ] Yuan Mei commented on FLINK-19693: -- Hey [~jinxing6...@126.com], Thanks so much for the

[jira] [Commented] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

2020-11-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17228962#comment-17228962 ] Yuan Mei commented on FLINK-20038: -- Redirect from FLINK-19693:   Hey, [~jinxing6...@1

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

2020-11-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232595#comment-17232595 ] Yuan Mei commented on FLINK-17726: -- Double checked with [~nicholasjiang], he said he wo

[jira] [Created] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-20252: Summary: Manual Test for Approximate Local Recovery Key: FLINK-20252 URL: https://issues.apache.org/jira/browse/FLINK-20252 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-20252: - Description: This  > Manual Test for Approximate Local Recovery > --

[jira] [Updated] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-20252: - Description: This manual test is to verify approximate failover works as expected in clusters.   Test

[jira] [Updated] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-20252: - Description: This manual test is to verify approximate failover works as expected in clusters.   *Tes

[jira] [Commented] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235878#comment-17235878 ] Yuan Mei commented on FLINK-20252: -- JM Log:   {code:java} 2020-11-20 11:05:40,914 INFO

[jira] [Comment Edited] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235878#comment-17235878 ] Yuan Mei edited comment on FLINK-20252 at 11/20/20, 3:59 AM: -

[jira] [Comment Edited] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235878#comment-17235878 ] Yuan Mei edited comment on FLINK-20252 at 11/20/20, 3:59 AM: -

[jira] [Comment Edited] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235884#comment-17235884 ] Yuan Mei edited comment on FLINK-20252 at 11/20/20, 4:04 AM: -

[jira] [Commented] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235884#comment-17235884 ] Yuan Mei commented on FLINK-20252: -- sink output:   {code:java} index:146; key:0; selec

[jira] [Commented] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-23 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237811#comment-17237811 ] Yuan Mei commented on FLINK-20252: -- [~rmetzger], yes. I just mark the issue as resolved

[jira] [Resolved] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-23 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei resolved FLINK-20252. -- Resolution: Fixed > Manual Test for Approximate Local Recovery > -

[jira] [Comment Edited] (FLINK-20252) Manual Test for Approximate Local Recovery

2020-11-23 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237811#comment-17237811 ] Yuan Mei edited comment on FLINK-20252 at 11/24/20, 3:01 AM: -

[jira] [Created] (FLINK-21018) Follow up of FLINK-20488 to update checkpoint related documentation

2021-01-18 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-21018: Summary: Follow up of FLINK-20488 to update checkpoint related documentation Key: FLINK-21018 URL: https://issues.apache.org/jira/browse/FLINK-21018 Project: Flink

[jira] [Updated] (FLINK-21018) Follow up of FLINK-20488 to update checkpoint related documentation for UI

2021-01-18 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-21018: - Summary: Follow up of FLINK-20488 to update checkpoint related documentation for UI (was: Follow up of

[jira] [Updated] (FLINK-21018) Follow up of FLINK-20488 to update checkpoint related documentation for UI

2021-01-20 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-21018: - Attachment: 屏幕快照 2021-01-21 上午11.38.25.png > Follow up of FLINK-20488 to update checkpoint related docum

[jira] [Updated] (FLINK-21018) Follow up of FLINK-20488 to update checkpoint related documentation for UI

2021-01-20 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-21018: - Attachment: 屏幕快照 2021-01-21 上午11.38.02.png > Follow up of FLINK-20488 to update checkpoint related docum

[jira] [Commented] (FLINK-21018) Follow up of FLINK-20488 to update checkpoint related documentation for UI

2021-01-20 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269012#comment-17269012 ] Yuan Mei commented on FLINK-21018: -- uploaded two screenshots for updated docs. > Follo

[jira] [Commented] (FLINK-21233) Race condition in CheckpointCoordinator in finishing sync savepoint

2021-02-03 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17278569#comment-17278569 ] Yuan Mei commented on FLINK-21233: -- Is this ticket completed? Why it is in "closed" sta

[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009452#comment-17009452 ] Yuan Mei commented on FLINK-14163: -- Accidentally navigating here when digging into the

[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010280#comment-17010280 ] Yuan Mei commented on FLINK-14163: -- That's a good point: fail loudly if acting in an un

[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011568#comment-17011568 ] Yuan Mei commented on FLINK-14163: -- Thanks for assigning the task to me!   I have wri

[jira] [Comment Edited] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011568#comment-17011568 ] Yuan Mei edited comment on FLINK-14163 at 1/9/20 9:06 AM: -- Than

[jira] [Comment Edited] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011568#comment-17011568 ] Yuan Mei edited comment on FLINK-14163 at 1/9/20 9:06 AM: -- Than

[jira] [Comment Edited] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011568#comment-17011568 ] Yuan Mei edited comment on FLINK-14163 at 1/9/20 9:34 AM: -- Than

[jira] [Comment Edited] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011568#comment-17011568 ] Yuan Mei edited comment on FLINK-14163 at 1/9/20 9:46 AM: -- Than

[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2020-01-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011657#comment-17011657 ] Yuan Mei commented on FLINK-14163: -- [~zhuzh] Thank you sooo much. I prefer option 3 bet

  1   2   3   4   5   6   7   8   >