[jira] [Commented] (FLINK-19774) Introduce sub partition view version for approximate Failover

2020-10-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219150#comment-17219150 ] Yuan Mei commented on FLINK-19774: -- Here is an example from [~roman_khachatryan] # downstream fails,

[jira] [Updated] (FLINK-19774) Introduce sub partition view version for approximate Failover

2020-10-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-19774: - Description: This is a follow-up ticket for [FLINK-19632] (was: This is a follow-up ticket for ) >

[jira] [Updated] (FLINK-19774) Introduce sub partition view version for approximate Failover

2020-10-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-19774: - Description:   This ticket is to solve a corner case where a downstream task continuously fails

[jira] [Updated] (FLINK-19774) Introduce sub partition view version for approximate Failover

2020-10-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-19774: - Description:   This ticket is to solve a corner case where a downstream task continuously fails

[jira] [Created] (FLINK-19774) Introduce sub partition view version for approximate Failover

2020-10-22 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-19774: Summary: Introduce sub partition view version for approximate Failover Key: FLINK-19774 URL: https://issues.apache.org/jira/browse/FLINK-19774 Project: Flink Issue

[jira] [Updated] (FLINK-19774) Introduce sub partition view version for approximate Failover

2020-10-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-19774: - Description: This is a follow-up ticket for  > Introduce sub partition view version for approximate

[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

[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

[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

[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

[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] [Comment Edited] (FLINK-20488) Show checkpoint type in the UI (AC/UC) for each subtask

2020-12-29 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256293#comment-17256293 ] Yuan Mei edited comment on FLINK-20488 at 12/30/20, 5:37 AM: - A bit more

[jira] [Commented] (FLINK-20488) Show checkpoint type in the UI (AC/UC) for each subtask

2020-12-29 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256293#comment-17256293 ] Yuan Mei commented on FLINK-20488: -- A bit more details:   On the high-level, people want to

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

2020-12-29 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256291#comment-17256291 ] Yuan Mei edited comment on FLINK-18983 at 12/30/20, 5:34 AM: - As [~liuyufei] 

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

2020-12-29 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256291#comment-17256291 ] Yuan Mei commented on FLINK-18983: -- As [~liuyufei] mentioned that they already have an internal

[jira] [Commented] (FLINK-20453) Move checkpointing classes to the appropriate package

2021-01-05 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258871#comment-17258871 ] Yuan Mei commented on FLINK-20453: -- If we do not move SubtaskCheckpointCoordinator(Impl), I think

[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

[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

[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=17269012#comment-17269012 ] Yuan Mei commented on FLINK-21018: -- uploaded two screenshots for updated docs. > Follow up of

[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] [Commented] (FLINK-20488) Show checkpoint type in the UI (AC/UC) for each subtask

2021-01-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258096#comment-17258096 ] Yuan Mei commented on FLINK-20488: -- In the first version, we probably do not need to distinguish

[jira] [Updated] (FLINK-20488) Show checkpoint type in the UI (AC/UC) for each subtask

2021-01-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-20488: - Attachment: 屏幕快照 2020-12-31 下午3.53.55.png > Show checkpoint type in the UI (AC/UC) for each subtask >

[jira] [Commented] (FLINK-20488) Show checkpoint type in the UI (AC/UC) for each subtask

2021-01-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258097#comment-17258097 ] Yuan Mei commented on FLINK-20488: -- !屏幕快照 2020-12-31 下午3.53.55.png! > Show checkpoint type in the UI

[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=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 6:31 AM: - Hey

[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=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 6:31 AM: - Hey

[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=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 7:13 AM: - Hey

[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=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 6:32 AM: - Hey

[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=17248736#comment-17248736 ] Yuan Mei edited comment on FLINK-18983 at 12/14/20, 6:32 AM: - Hey

[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=17278569#comment-17278569 ] Yuan Mei commented on FLINK-21233: -- Is this ticket completed? Why it is in "closed" status? > Race

[jira] [Comment Edited] (FLINK-23003) Resource leak in RocksIncrementalSnapshotStrategy

2021-06-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364027#comment-17364027 ] Yuan Mei edited comment on FLINK-23003 at 6/16/21, 2:53 AM: cc [~yunta]

[jira] [Comment Edited] (FLINK-23003) Resource leak in RocksIncrementalSnapshotStrategy

2021-06-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364027#comment-17364027 ] Yuan Mei edited comment on FLINK-23003 at 6/16/21, 2:51 AM: cc [~yunta]

[jira] [Commented] (FLINK-23003) Resource leak in RocksIncrementalSnapshotStrategy

2021-06-15 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364027#comment-17364027 ] Yuan Mei commented on FLINK-23003: -- cc [~yunta] [~roman_khachatryan]hatryan > Resource leak in

[jira] [Updated] (FLINK-22678) Hide ChangelogStateBackend From Users

2021-06-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22678: - Description: Per discussion on the mailing thread:

[jira] [Updated] (FLINK-22678) Hide ChangelogStateBackend From Users

2021-06-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22678: - Summary: Hide ChangelogStateBackend From Users (was: Fix Loading Changelog Statebackend with configs

[jira] [Updated] (FLINK-22678) Hide ChangelogStateBackend From Users

2021-06-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22678: - Fix Version/s: 1.14.0 > Hide ChangelogStateBackend From Users > --

[jira] [Commented] (FLINK-22678) Hide ChangelogStateBackend From Users

2021-06-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360623#comment-17360623 ] Yuan Mei commented on FLINK-22678: -- [~nicholasjiang] It is not that simple, please check the google doc

[jira] [Commented] (FLINK-22678) Hide ChangelogStateBackend From Users

2021-06-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360621#comment-17360621 ] Yuan Mei commented on FLINK-22678: -- [~Zakelly] Please go ahead. > Hide ChangelogStateBackend From

[jira] [Commented] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365228#comment-17365228 ] Yuan Mei commented on FLINK-22420: -- After syncing up with [~pnowojski] offline, removing

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365228#comment-17365228 ] Yuan Mei edited comment on FLINK-22420 at 6/18/21, 3:34 AM: After syncing up

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365228#comment-17365228 ] Yuan Mei edited comment on FLINK-22420 at 6/18/21, 3:36 AM: After syncing up

[jira] [Commented] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-21 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366530#comment-17366530 ] Yuan Mei commented on FLINK-22420: -- Hey [~trohrmann], thanks for replying! RPC timeout failure rarely

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-21 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366530#comment-17366530 ] Yuan Mei edited comment on FLINK-22420 at 6/21/21, 10:42 AM: - Hey

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-21 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366530#comment-17366530 ] Yuan Mei edited comment on FLINK-22420 at 6/21/21, 10:55 AM: - Hey

[jira] [Issue Comment Deleted] (FLINK-21448) Test Changelog State backend (Wrapper)

2021-06-21 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-21448: - Comment: was deleted (was: [~zhangyy91]) > Test Changelog State backend (Wrapper) >

[jira] [Commented] (FLINK-21448) Test Changelog State backend (Wrapper)

2021-06-21 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366499#comment-17366499 ] Yuan Mei commented on FLINK-21448: -- [~zhangyy91] > Test Changelog State backend (Wrapper) >

[jira] [Commented] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364758#comment-17364758 ] Yuan Mei commented on FLINK-22420: -- The failure of this task is caused by "Recovery is suppressed by

[jira] [Commented] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364765#comment-17364765 ] Yuan Mei commented on FLINK-22420: -- I did see in FLINK-21996 that a second option/solution is mentioned

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364758#comment-17364758 ] Yuan Mei edited comment on FLINK-22420 at 6/17/21, 7:52 AM: The failure of

[jira] [Created] (FLINK-22678) Fix Loading Changelog Statebackend with configs set in job-level and cluster-level separately

2021-05-16 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-22678: Summary: Fix Loading Changelog Statebackend with configs set in job-level and cluster-level separately Key: FLINK-22678 URL: https://issues.apache.org/jira/browse/FLINK-22678

[jira] [Updated] (FLINK-22678) Fix Loading Changelog Statebackend with configs set in job-level and cluster-level separately

2021-05-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22678: - Description: To enable/config Changelog Statebackend, we need to set 1.

[jira] [Updated] (FLINK-22678) Fix Loading Changelog Statebackend with configs set in job-level and cluster-level separately

2021-05-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22678: - Description: To enable/config Changelog Statebackend, we need to set 1.

[jira] [Updated] (FLINK-22678) Fix Loading Changelog Statebackend with configs set in job-level and cluster-level separately

2021-05-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22678: - Description: To enable/config Changelog Statebackend, we need to set 1.

[jira] [Updated] (FLINK-22678) Fix Loading Changelog Statebackend with configs set in job-level and cluster-level separately

2021-05-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22678: - Description: To enable/config > Fix Loading Changelog Statebackend with configs set in job-level and

[jira] [Comment Edited] (FLINK-21469) stop-with-savepoint --drain doesn't advance watermark for sources chained to MultipleInputStreamTask

2021-05-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341661#comment-17341661 ] Yuan Mei edited comment on FLINK-21469 at 5/10/21, 4:56 AM: For stop with

[jira] [Comment Edited] (FLINK-21469) stop-with-savepoint --drain doesn't advance watermark for sources chained to MultipleInputStreamTask

2021-05-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341661#comment-17341661 ] Yuan Mei edited comment on FLINK-21469 at 5/10/21, 4:56 AM: For stop with

[jira] [Commented] (FLINK-21469) stop-with-savepoint --drain doesn't advance watermark for sources chained to MultipleInputStreamTask

2021-05-09 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341661#comment-17341661 ] Yuan Mei commented on FLINK-21469: -- For stop with save point, `StreamTask#advanceToEndOfEventTime()`

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-07-02 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373893#comment-17373893 ] Yuan Mei edited comment on FLINK-22420 at 7/3/21, 4:28 AM: --- Have shared the

[jira] [Commented] (FLINK-22420) UnalignedCheckpointITCase failed

2021-07-02 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373893#comment-17373893 ] Yuan Mei commented on FLINK-22420: -- Have shared the full log offline. Can not upload the full log here

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370453#comment-17370453 ] Yuan Mei edited comment on FLINK-22420 at 6/28/21, 11:40 AM: - Double-checked

[jira] [Commented] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370557#comment-17370557 ] Yuan Mei commented on FLINK-22420: -- If we look at the FLINK-22417 (another failing ITCase), it fails

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370557#comment-17370557 ] Yuan Mei edited comment on FLINK-22420 at 6/28/21, 11:59 AM: - If we look at

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370557#comment-17370557 ] Yuan Mei edited comment on FLINK-22420 at 6/28/21, 11:59 AM: - If we look at

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370453#comment-17370453 ] Yuan Mei edited comment on FLINK-22420 at 6/28/21, 11:43 AM: - Double-checked

[jira] [Commented] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370689#comment-17370689 ] Yuan Mei commented on FLINK-22420: -- It seems the artifacts are already cleared, I attached the logs in

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370557#comment-17370557 ] Yuan Mei edited comment on FLINK-22420 at 6/28/21, 4:00 PM: If we look at

[jira] [Issue Comment Deleted] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-22420: - Comment: was deleted (was: It seems the artifacts are already cleared, I attached the logs in this

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370453#comment-17370453 ] Yuan Mei edited comment on FLINK-22420 at 6/28/21, 11:34 AM: - Double-checked

[jira] [Created] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose rocksdb properly, and fails the test

2021-07-12 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-23367: Summary: testKeyGroupedInternalPriorityQueue does not dispose rocksdb properly, and fails the test Key: FLINK-23367 URL: https://issues.apache.org/jira/browse/FLINK-23367

[jira] [Updated] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose rocksdb properly, and fails the test

2021-07-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-23367: - Description: The set of `testKeyGroupedInternalPriorityQueue` for

[jira] [Updated] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose rocksdb properly, and fails the test

2021-07-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-23367: - Parent: FLINK-21352 Issue Type: Sub-task (was: Bug) > testKeyGroupedInternalPriorityQueue does

[jira] [Updated] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

2021-07-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-23367: - Summary: testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB

[jira] [Commented] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370453#comment-17370453 ] Yuan Mei commented on FLINK-22420: -- {{14:27:02,335 [Source: source (1/1)#5] INFO

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370453#comment-17370453 ] Yuan Mei edited comment on FLINK-22420 at 6/28/21, 7:17 AM: ```

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370453#comment-17370453 ] Yuan Mei edited comment on FLINK-22420 at 6/28/21, 7:18 AM:

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370453#comment-17370453 ] Yuan Mei edited comment on FLINK-22420 at 6/28/21, 7:19 AM: {code:java}

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370453#comment-17370453 ] Yuan Mei edited comment on FLINK-22420 at 6/28/21, 7:29 AM: Double-checked

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17370453#comment-17370453 ] Yuan Mei edited comment on FLINK-22420 at 6/28/21, 7:44 AM: Double-checked

[jira] [Comment Edited] (FLINK-21469) stop-with-savepoint --drain doesn't advance watermark for sources chained to MultipleInputStreamTask

2021-04-27 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333013#comment-17333013 ] Yuan Mei edited comment on FLINK-21469 at 4/27/21, 7:51 AM: working on this

[jira] [Commented] (FLINK-21469) stop-with-savepoint --drain doesn't advance watermark for sources chained to MultipleInputStreamTask

2021-04-27 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333013#comment-17333013 ] Yuan Mei commented on FLINK-21469: -- working on this. > stop-with-savepoint --drain doesn't advance

[jira] [Comment Edited] (FLINK-21469) stop-with-savepoint --drain doesn't advance watermark for sources chained to MultipleInputStreamTask

2021-04-27 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333013#comment-17333013 ] Yuan Mei edited comment on FLINK-21469 at 4/27/21, 7:51 AM: working on this.

[jira] [Commented] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

2021-04-29 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337075#comment-17337075 ] Yuan Mei commented on FLINK-21317: -- cc [~AHeise] since he mentioned this might be included within the

[jira] [Created] (FLINK-22403) Update Chinese version of JDBC sink docs

2021-04-22 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-22403: Summary: Update Chinese version of JDBC sink docs Key: FLINK-22403 URL: https://issues.apache.org/jira/browse/FLINK-22403 Project: Flink Issue Type: Task

[jira] [Comment Edited] (FLINK-21013) Blink planner does not ingest timestamp into StreamRecord

2021-02-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280752#comment-17280752 ] Yuan Mei edited comment on FLINK-21013 at 2/8/21, 5:18 AM: --- Hey [~Leonard Xu]

[jira] [Comment Edited] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

2021-02-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280814#comment-17280814 ] Yuan Mei edited comment on FLINK-21317 at 2/8/21, 7:33 AM: --- Hey [~kezhuw],

[jira] [Commented] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

2021-02-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280814#comment-17280814 ] Yuan Mei commented on FLINK-21317: -- Hey [~kezhuw], thanks very much for reporting this. The current

[jira] [Comment Edited] (FLINK-21013) Blink planner does not ingest timestamp into StreamRecord

2021-02-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280752#comment-17280752 ] Yuan Mei edited comment on FLINK-21013 at 2/8/21, 5:16 AM: --- Hey [~Leonard Xu]

[jira] [Commented] (FLINK-21013) Blink planner does not ingest timestamp into StreamRecord

2021-02-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280752#comment-17280752 ] Yuan Mei commented on FLINK-21013: -- Hey [~Leonard Xu] and [~jark], what is the status of this ticket?

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-02-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280756#comment-17280756 ] Yuan Mei commented on FLINK-20663: -- [~ykt836] mentioned it is better to include this ticket in 1.12.2;

[jira] [Comment Edited] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

2021-02-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280754#comment-17280754 ] Yuan Mei edited comment on FLINK-20417 at 2/8/21, 5:21 AM: --- Sync-up offline

[jira] [Commented] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

2021-02-07 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17280754#comment-17280754 ] Yuan Mei commented on FLINK-20417: -- Sync-up offline with Yang, PR will be merged on Feb. 9. > Handle

[jira] [Created] (FLINK-22004) Translate Flink Roadmap to Chinese.

2021-03-28 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-22004: Summary: Translate Flink Roadmap to Chinese. Key: FLINK-22004 URL: https://issues.apache.org/jira/browse/FLINK-22004 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-21743) JdbcXaSinkFunction throws XAER_RMFAIL when calling snapshotState and beginTx

2021-04-06 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315273#comment-17315273 ] Yuan Mei commented on FLINK-21743: -- Hey [~weihao], I've tried on the latest version of MySQL (8.0), the

[jira] [Comment Edited] (FLINK-21743) JdbcXaSinkFunction throws XAER_RMFAIL when calling snapshotState and beginTx

2021-04-06 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17315273#comment-17315273 ] Yuan Mei edited comment on FLINK-21743 at 4/6/21, 6:51 AM: --- Hey [~weihao],

[jira] [Commented] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

2021-03-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17298692#comment-17298692 ] Yuan Mei commented on FLINK-21317: -- Hey [~kezhuw], thanks very much for reporting the bug. That's

[jira] [Comment Edited] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

2021-03-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17298692#comment-17298692 ] Yuan Mei edited comment on FLINK-21317 at 3/10/21, 10:48 AM: - Hey [~kezhuw],

[jira] [Updated] (FLINK-21448) Test Changelog State backend (Wrapper)

2021-02-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-21448: - Description: This is a follow-up ticket for FLINK-21354 After was:This is a follow up ticket for

[jira] [Updated] (FLINK-21448) Test Changelog State backend (Wrapper)

2021-02-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-21448: - Description: This is a follow-up ticket for FLINK-21354 ChangelogStatebackend is a wrapper on top of

[jira] [Created] (FLINK-21448) Test Changelog State backend

2021-02-22 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-21448: Summary: Test Changelog State backend Key: FLINK-21448 URL: https://issues.apache.org/jira/browse/FLINK-21448 Project: Flink Issue Type: Sub-task

<    1   2   3   4   5   6   7   8   >