[jira] [Commented] (FLINK-28262) The select result does not match the sink table

[ https://issues.apache.org/jira/browse/FLINK-28262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566719#comment-17566719 ] EMing Zhou commented on FLINK-28262: [~simen] ，I agree with [~Leo Zhou] 's point of

[jira] [Comment Edited] (FLINK-28027) Initialise Async Sink maximum number of in flight messages to low number for rate limiting strategy

[ https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555460#comment-17555460 ] EMing Zhou edited comment on FLINK-28027 at 6/17/22 8:28 AM: -

[jira] [Comment Edited] (FLINK-28027) Initialise Async Sink maximum number of in flight messages to low number for rate limiting strategy

[ https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555460#comment-17555460 ] EMing Zhou edited comment on FLINK-28027 at 6/17/22 8:28 AM: -

[jira] [Comment Edited] (FLINK-28027) Initialise Async Sink maximum number of in flight messages to low number for rate limiting strategy

[ https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555460#comment-17555460 ] EMing Zhou edited comment on FLINK-28027 at 6/17/22 8:21 AM: -

[jira] [Commented] (FLINK-28027) Initialise Async Sink maximum number of in flight messages to low number for rate limiting strategy

[ https://issues.apache.org/jira/browse/FLINK-28027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555460#comment-17555460 ] EMing Zhou commented on FLINK-28027: Hi [~CrynetLogistics] ，When I use jdbc sink, I

[jira] [Commented] (FLINK-27971) [JUnit5 Migration] Module: flink-json

[ https://issues.apache.org/jira/browse/FLINK-27971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553991#comment-17553991 ] EMing Zhou commented on FLINK-27971: Hi [~rskraba]  ，I have already upgraded the fli

[jira] [Commented] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543006#comment-17543006 ] EMing Zhou commented on FLINK-27734: Hi [~Feifan Wang]     I also found that it may

[jira] [Commented] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542970#comment-17542970 ] EMing Zhou commented on FLINK-27734: Hi [~Feifan Wang]  So I think this value should

[jira] [Comment Edited] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542839#comment-17542839 ] EMing Zhou edited comment on FLINK-27734 at 5/27/22 12:55 PM:

[jira] [Comment Edited] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542839#comment-17542839 ] EMing Zhou edited comment on FLINK-27734 at 5/27/22 12:12 PM:

[jira] [Commented] (FLINK-27797) PythonTableUtils.getCollectionInputFormat cannot correctly handle None values

[ https://issues.apache.org/jira/browse/FLINK-27797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542882#comment-17542882 ] EMing Zhou commented on FLINK-27797: can I get this ticket？ > PythonTableUtils.getC

[jira] [Commented] (FLINK-27734) Not showing checkpoint interval properly in WebUI when checkpoint is disabled

[ https://issues.apache.org/jira/browse/FLINK-27734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17542839#comment-17542839 ] EMing Zhou commented on FLINK-27734: Hi [~Feifan Wang]       I took a look at the p

[jira] [Comment Edited] (FLINK-27587) Support keyed co-broadcast processing in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-27587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1753#comment-1753 ] EMing Zhou edited comment on FLINK-27587 at 5/20/22 9:07 AM: -

[jira] [Commented] (FLINK-27587) Support keyed co-broadcast processing in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-27587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1753#comment-1753 ] EMing Zhou commented on FLINK-27587: Hi [~Juntao Hu]  This issue seems to be submitt

[jira] [Commented] (FLINK-27570) A checkpoint path error does not cause the job to stop

[ https://issues.apache.org/jira/browse/FLINK-27570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17539970#comment-17539970 ] EMing Zhou commented on FLINK-27570: Hi  Can you provide the details of the checkpoi

[jira] [Commented] (FLINK-27352) [JUnit5 Migration] Module: flink-json

[ https://issues.apache.org/jira/browse/FLINK-27352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526450#comment-17526450 ] EMing Zhou commented on FLINK-27352: Hi, Can you assigne to me?Thank you. > [JUnit5

[jira] (FLINK-27340) [JUnit5 Migration] Module: flink-python

[ https://issues.apache.org/jira/browse/FLINK-27340 ] EMing Zhou deleted comment on FLINK-27340: was (Author: zsigner): Hi [~Sergey Nuyanzin]      Can I get the ticket?   > [JUnit5 Migration] Module: flink-python > ---

[jira] [Updated] (FLINK-27352) [JUnit5 Migration] Module: flink-json

[ https://issues.apache.org/jira/browse/FLINK-27352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] EMing Zhou updated FLINK-27352: --- Affects Version/s: (was: 1.16.0) > [JUnit5 Migration] Module: flink-json > -

[jira] [Created] (FLINK-27352) [JUnit5 Migration] Module: flink-json

EMing Zhou created FLINK-27352: -- Summary: [JUnit5 Migration] Module: flink-json Key: FLINK-27352 URL: https://issues.apache.org/jira/browse/FLINK-27352 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-27340) [JUnit5 Migration] Module: flink-python

[ https://issues.apache.org/jira/browse/FLINK-27340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17526234#comment-17526234 ] EMing Zhou commented on FLINK-27340: Hi [~Sergey Nuyanzin]      Can I get the ticke