[jira] [Commented] (FLINK-27251) Timeout aligned to unaligned checkpoint barrier in the output buffers of an upstream subtask

[ https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17541863#comment-17541863 ] fanrui commented on FLINK-27251: [~pnowojski] Thanks a lot for your guidance and help. In the process of

[jira] [Commented] (FLINK-27251) Timeout aligned to unaligned checkpoint barrier in the output buffers of an upstream subtask

[ https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538730#comment-17538730 ] Piotr Nowojski commented on FLINK-27251: Thanks [~fanrui] for the update. I will take a look :)

[jira] [Commented] (FLINK-27251) Timeout aligned to unaligned checkpoint barrier in the output buffers of an upstream subtask

[ https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537192#comment-17537192 ] fanrui commented on FLINK-27251: Hi [~pnowojski] I have addressed your all suggestions, including: *

[jira] [Commented] (FLINK-27251) Timeout aligned to unaligned checkpoint barrier in the output buffers of an upstream subtask

[ https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536102#comment-17536102 ] fanrui commented on FLINK-27251: Thanks for your suggestions. Re 4, your are right. There is one 

[jira] [Commented] (FLINK-27251) Timeout aligned to unaligned checkpoint barrier in the output buffers of an upstream subtask

[ https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536089#comment-17536089 ] Piotr Nowojski commented on FLINK-27251: Thanks for the answers. Re 3., thanks for the pointers,

[jira] [Commented] (FLINK-27251) Timeout aligned to unaligned checkpoint barrier in the output buffers of an upstream subtask

[ https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534911#comment-17534911 ] fanrui commented on FLINK-27251: Thanks for your comments.  For comment 1 and 2, you're right. It's

[jira] [Commented] (FLINK-27251) Timeout aligned to unaligned checkpoint barrier in the output buffers of an upstream subtask

[ https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534876#comment-17534876 ] Piotr Nowojski commented on FLINK-27251: I've looked at the code and I have a couple of high

[jira] [Commented] (FLINK-27251) Timeout aligned to unaligned checkpoint barrier in the output buffers of an upstream subtask

[ https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534774#comment-17534774 ] fanrui commented on FLINK-27251: Hi [~pnowojski] This is my POC code :

[jira] [Commented] (FLINK-27251) Timeout aligned to unaligned checkpoint barrier in the output buffers of an upstream subtask

[ https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534356#comment-17534356 ] fanrui commented on FLINK-27251: Hi [~pnowojski] , thanks for your reply and some useful information.