[jira] [Updated] (FLINK-35804) Incorrect calc merge generate wrong plan about udtf+join+udf

2024-07-10 Thread roncenzhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] roncenzhao updated FLINK-35804: --- Description: Like the same issue in FLINK-30841. Take one test as example: {code:java} @Test def te

[jira] [Updated] (FLINK-35804) Incorrect calc merge generate wrong plan about udtf+join+udf

2024-07-10 Thread roncenzhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] roncenzhao updated FLINK-35804: --- Description: Like the same issue in FLINK-30841. Take one test as example: {code:java} @Test def te

[jira] [Updated] (FLINK-35804) Incorrect calc merge generate wrong plan about udtf+join+udf

2024-07-10 Thread roncenzhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] roncenzhao updated FLINK-35804: --- Description: Like the same issue in FLINK-30841. Take one test as example:   {code:java} @Test def

[jira] [Updated] (FLINK-35804) Incorrect calc merge generate wrong plan about udtf+join+udf

2024-07-10 Thread roncenzhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] roncenzhao updated FLINK-35804: --- Description: Like the same issue in FLINK-30841. Take one test as example: {code:java} @Test def te

[jira] [Updated] (FLINK-35804) Incorrect calc merge generate wrong plan about udtf+join+udf

2024-07-10 Thread roncenzhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] roncenzhao updated FLINK-35804: --- Description: Like the same issue in FLINK-30841. Take one test as example: ``` @Test def testCalcM

[jira] [Created] (FLINK-35804) Incorrect calc merge generate wrong plan about udtf+join+udf

2024-07-10 Thread roncenzhao (Jira)
roncenzhao created FLINK-35804: -- Summary: Incorrect calc merge generate wrong plan about udtf+join+udf Key: FLINK-35804 URL: https://issues.apache.org/jira/browse/FLINK-35804 Project: Flink Iss

[jira] [Commented] (FLINK-15396) Support to ignore parse errors for JSON format

2020-03-01 Thread roncenzhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17048731#comment-17048731 ] roncenzhao commented on FLINK-15396: Hi, guys. Is there any progress about this pr?

[jira] [Commented] (FLINK-16334) flink-sql kafka-connector support ignore the invalid data during parsing bytes to json row

2020-02-29 Thread roncenzhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17048463#comment-17048463 ] roncenzhao commented on FLINK-16334: [~libenchao] Thank you and I will close this is

[jira] [Closed] (FLINK-16334) flink-sql kafka-connector support ignore the invalid data during parsing bytes to json row

2020-02-29 Thread roncenzhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] roncenzhao closed FLINK-16334. -- Resolution: Duplicate > flink-sql kafka-connector support ignore the invalid data during parsing > by

[jira] [Created] (FLINK-16334) flink-sql kafka-connector support ignore the invalid data during parsing bytes to json row

2020-02-28 Thread roncenzhao (Jira)
roncenzhao created FLINK-16334: -- Summary: flink-sql kafka-connector support ignore the invalid data during parsing bytes to json row Key: FLINK-16334 URL: https://issues.apache.org/jira/browse/FLINK-16334