[jira] [Updated] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-29545: -- Description: the task dag is like attached file. when the task is started to consume from ear

[jira] [Commented] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614415#comment-17614415 ] xiaogang zhou commented on FLINK-29545: --- i can help collect if further evidence ne

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614415#comment-17614415 ] xiaogang zhou edited comment on FLINK-29545 at 10/8/22 8:24 AM: --

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614415#comment-17614415 ] xiaogang zhou edited comment on FLINK-29545 at 10/8/22 8:26 AM: --

[jira] [Updated] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-29545: -- Description: the task dag is like attached file. when the task is started to consume from ear

[jira] [Updated] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-29545: -- Description: the task dag is like attached file. when the task is started to consume from ear

[jira] [Commented] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666 ] xiaogang zhou commented on FLINK-29545: --- 1， yes, I have debug this task to many ti

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666 ] xiaogang zhou edited comment on FLINK-29545 at 10/9/22 9:11 AM: --

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666 ] xiaogang zhou edited comment on FLINK-29545 at 10/9/22 9:22 AM: --

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666 ] xiaogang zhou edited comment on FLINK-29545 at 10/9/22 9:27 AM: --

[jira] [Commented] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614698#comment-17614698 ] xiaogang zhou commented on FLINK-29545: ---  I tried to get some info when block happ

[jira] [Comment Edited] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666 ] xiaogang zhou edited comment on FLINK-29545 at 10/10/22 2:01 AM: -

[jira] [Updated] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-29545: -- Description: the task dag is like attached file. the task is started to consume from earliest

[jira] [Commented] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615416#comment-17615416 ] xiaogang zhou commented on FLINK-29545: --- [~martijnvisser] this can also happen in

[jira] [Commented] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616338#comment-17616338 ] xiaogang zhou commented on FLINK-29545: --- [~martijnvisser]  Can you please suggest

[jira] [Updated] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-29545: -- Description: the task dag is like attached file. the task is started to consume from earliest

[jira] [Commented] (FLINK-22882) Tasks are blocked while emitting records

[ https://issues.apache.org/jira/browse/FLINK-22882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617507#comment-17617507 ] xiaogang zhou commented on FLINK-22882: ---       at org.apache.flink.runtime.io.net

[jira] [Commented] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618686#comment-17618686 ] xiaogang zhou commented on FLINK-29545: --- [~pnowojski] This turns out to be a netwo

[jira] [Commented] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618867#comment-17618867 ] xiaogang zhou commented on FLINK-29545: --- Sorry， I was to rude to get the network i

[jira] [Commented] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618917#comment-17618917 ] xiaogang zhou commented on FLINK-29545: --- [~pnowojski]  [https://github.com/apache

[jira] (FLINK-29545) kafka consuming stop when trigger first checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29545 ] xiaogang zhou deleted comment on FLINK-29545: --- was (Author: zhoujira86): [~pnowojski]  [https://github.com/apache/flink/pull/21080] Hi Master, I have modified the commit a little bit. the

[jira] [Issue Comment Deleted] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-17808: -- Comment: was deleted (was: [~yunta] Let me know your thinking :)) > Rename checkpoint meta fi

[jira] [Commented] (FLINK-34979) Implement State Future and related utilities

[ https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927903#comment-17927903 ] xiaogang zhou commented on FLINK-34979: --- is it possible to pass exception in the c

[jira] [Commented] (FLINK-34979) Implement State Future and related utilities

[ https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928051#comment-17928051 ] xiaogang zhou commented on FLINK-34979: --- [~zakelly] As user might use thenCompose,

[jira] [Commented] (FLINK-34979) Implement State Future and related utilities

[ https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928052#comment-17928052 ] xiaogang zhou commented on FLINK-34979: --- e.g. an operator has several states, and

[jira] [Comment Edited] (FLINK-34979) Implement State Future and related utilities

[ https://issues.apache.org/jira/browse/FLINK-34979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927903#comment-17927903 ] xiaogang zhou edited comment on FLINK-34979 at 2/18/25 8:54 AM: --

<    1   2   3