[jira] [Commented] (FLINK-22541) add json format filter params

[ https://issues.apache.org/jira/browse/FLINK-22541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17339967#comment-17339967 ] sandy du commented on FLINK-22541: -- Hi [~jark] ，I wanna  contribute  this issue，can you assess the

[jira] [Updated] (FLINK-22541) add json format filter params

[ https://issues.apache.org/jira/browse/FLINK-22541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sandy du updated FLINK-22541: - Attachment: image-2021-05-06-13-37-49-160.png > add json format filter params >

[jira] [Commented] (FLINK-22541) add json format filter params

[ https://issues.apache.org/jira/browse/FLINK-22541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17339972#comment-17339972 ] sandy du commented on FLINK-22541: -- Params path-fliter and path-data  are optional, they don't affect

[jira] [Updated] (FLINK-22541) add json format filter params

[ https://issues.apache.org/jira/browse/FLINK-22541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sandy du updated FLINK-22541: - Attachment: image-2021-05-06-13-38-37-284.png > add json format filter params >

[jira] [Commented] (FLINK-22541) add json format filter params

[ https://issues.apache.org/jira/browse/FLINK-22541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340006#comment-17340006 ] sandy du commented on FLINK-22541: -- yes,I will add  some codes  in 

[jira] [Commented] (FLINK-22541) add json format filter params

[ https://issues.apache.org/jira/browse/FLINK-22541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337735#comment-17337735 ] sandy du commented on FLINK-22541: -- could you  assign this issue to me？ > add json format filter

[jira] [Updated] (FLINK-22541) add json format filter params

[ https://issues.apache.org/jira/browse/FLINK-22541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sandy du updated FLINK-22541: - Description: In my case,one kafka topic store multiple table data，for example：

[jira] [Created] (FLINK-22541) add json format filter params

sandy du created FLINK-22541: Summary: add json format filter params Key: FLINK-22541 URL: https://issues.apache.org/jira/browse/FLINK-22541 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-24412) retract stream join on topN error

[ https://issues.apache.org/jira/browse/FLINK-24412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422597#comment-17422597 ] sandy du commented on FLINK-24412: -- [~jark]  Would you help me look this issue? > retract stream

[jira] [Updated] (FLINK-24412) retract stream join on topN error

[ https://issues.apache.org/jira/browse/FLINK-24412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sandy du updated FLINK-24412: - Description: I can  reappear this error in follow sql： create table user_info( name string, age int,

[jira] [Created] (FLINK-24412) retract stream join on topN error

sandy du created FLINK-24412: Summary: retract stream join on topN error Key: FLINK-24412 URL: https://issues.apache.org/jira/browse/FLINK-24412 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27949) kafka create topic error

sandy du created FLINK-27949: Summary: kafka create topic error Key: FLINK-27949 URL: https://issues.apache.org/jira/browse/FLINK-27949 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-27949) kafka create topic error

[ https://issues.apache.org/jira/browse/FLINK-27949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sandy du updated FLINK-27949: - Description: {{kafka version:2.1.1}}   {{org.apache.kafka.common.errors.UnsupportedVersionException: