[jira] [Comment Edited] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-13 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379694#comment-17379694 ] longwang0616 edited comment on FLINK-22969 at 7/13/21, 7:52 AM: Hello , 

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-13 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379694#comment-17379694 ] longwang0616 commented on FLINK-22969: -- Hello ,  [~fsk119] [~luoyuxia] if you think it is necessary

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-13 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379669#comment-17379669 ] longwang0616 commented on FLINK-22969: -- [~fsk119] Thank you for letting me know that I have this

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-13 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379643#comment-17379643 ] longwang0616 commented on FLINK-22969: -- [~fsk119]，[~luoyuxia] I think Sql api can be verified like

[jira] [Comment Edited] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-12 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379552#comment-17379552 ] longwang0616 edited comment on FLINK-22969 at 7/13/21, 3:43 AM:

[jira] [Comment Edited] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-12 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379552#comment-17379552 ] longwang0616 edited comment on FLINK-22969 at 7/13/21, 3:41 AM:

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-12 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-13-11-20-22-134.png > Validate the topic is not null or empty string

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-12 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379552#comment-17379552 ] longwang0616 commented on FLINK-22969: -- [~luoyuxia] I found through debug that when he executes

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-12 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-13-11-15-47-392.png > Validate the topic is not null or empty string

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-12 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-13-11-15-06-977.png > Validate the topic is not null or empty string

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-12 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-13-11-03-30-740.png > Validate the topic is not null or empty string

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-12 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-13-11-02-37-451.png > Validate the topic is not null or empty string

[jira] [Commented] (FLINK-23352) Collect Sink Operator Factory does not support to configure max bytes per batch

2021-07-12 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378999#comment-17378999 ] longwang0616 commented on FLINK-23352: -- [~TsReaper]okay, thank you > Collect Sink Operator Factory

[jira] [Commented] (FLINK-23352) Collect Sink Operator Factory does not support to configure max bytes per batch

2021-07-12 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378994#comment-17378994 ] longwang0616 commented on FLINK-23352: -- Hello, is CollectSinkOperatorFactory created by executing

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-11 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378865#comment-17378865 ] longwang0616 commented on FLINK-22969: -- [~luoyuxia]Hello, maybe it is not what we understand? >

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-07 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17376971#comment-17376971 ] longwang0616 commented on FLINK-22969: -- [~luoyuxia] Hello, I created a pull request, please review

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-07 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17376953#comment-17376953 ] longwang0616 commented on FLINK-22969: -- okay, thank you. > Validate the topic is not null or empty

[jira] [Commented] (FLINK-14998) Remove FileUtils#deletePathIfEmpty

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17376150#comment-17376150 ] longwang0616 commented on FLINK-14998: -- [~yunta]I'll delete this method, please assign this problem

[jira] [Comment Edited] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375513#comment-17375513 ] longwang0616 edited comment on FLINK-22969 at 7/6/21, 2:45 PM: --- [~fsk119] 

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-06-19-07-01-607.png > Validate the topic is not null or empty string

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17375513#comment-17375513 ] longwang0616 commented on FLINK-22969: -- [~fsk119] Hello! I am interested in this question, can it

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-06-19-07-27-936.png > Validate the topic is not null or empty string

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-06-19-05-48-964.png > Validate the topic is not null or empty string

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-06-19-04-53-651.png > Validate the topic is not null or empty string

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-06-19-04-16-530.png > Validate the topic is not null or empty string

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-06-19-03-32-050.png > Validate the topic is not null or empty string

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-06-19-03-22-899.png > Validate the topic is not null or empty string

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-06-19-01-22-483.png > Validate the topic is not null or empty string

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-06-18-55-54-109.png > Validate the topic is not null or empty string

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-06 Thread longwang0616 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] longwang0616 updated FLINK-22969: - Attachment: image-2021-07-06-18-55-22-235.png > Validate the topic is not null or empty string