[jira] [Commented] (FLINK-34305) Release Testing Instructions: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

2024-02-20 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818800#comment-17818800 ] SuDewei commented on FLINK-34305: - [~lincoln.86xy] I will complete this document before

[jira] [Created] (FLINK-34500) Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

2024-02-22 Thread SuDewei (Jira)
SuDewei created FLINK-34500: --- Summary: Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources Key: FLINK-34500 URL: https://issues.apache.org/jira/browse/FLINK-34500 Project:

[jira] [Updated] (FLINK-34500) Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

2024-02-22 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] SuDewei updated FLINK-34500: Description: This issue aims to verify [FLIP-367|https://cwiki.apache.org/confluence/pages/viewpage.actio

[jira] [Commented] (FLINK-34305) Release Testing Instructions: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

2024-02-22 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819715#comment-17819715 ] SuDewei commented on FLINK-34305: - [~lincoln.86xy] [~Zhanghao Chen] Hi, the docs is read

[jira] [Comment Edited] (FLINK-34305) Release Testing Instructions: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

2024-02-22 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819715#comment-17819715 ] SuDewei edited comment on FLINK-34305 at 2/22/24 4:30 PM: -- [~li

[jira] [Commented] (FLINK-33263) Implement ParallelismProvider for sources in the table planner

2024-01-10 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805086#comment-17805086 ] SuDewei commented on FLINK-33263: - Hi [~libenchao]  I’m willing to doing this, shall I

[jira] [Commented] (FLINK-32609) Kafka table source supports projection push down

2024-01-23 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17809803#comment-17809803 ] SuDewei commented on FLINK-32609: - [~lsy] Hi dalong, do you have time to continue this w

[jira] [Commented] (FLINK-33265) Support source parallelism setting for Kafka connector

2024-01-29 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812161#comment-17812161 ] SuDewei commented on FLINK-33265: - Hi [~lincoln.86xy]  , I’m willing to doing this, shal

[jira] [Created] (FLINK-35324) Avro format can not perform projection pushdown for specific fields

2024-05-09 Thread SuDewei (Jira)
SuDewei created FLINK-35324: --- Summary: Avro format can not perform projection pushdown for specific fields Key: FLINK-35324 URL: https://issues.apache.org/jira/browse/FLINK-35324 Project: Flink Is

[jira] [Updated] (FLINK-35324) Avro format can not perform projection pushdown for specific fields

2024-05-09 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] SuDewei updated FLINK-35324: Description: AvroFormatFactory.java#createDecodingFormat would return a ProjectableDecodingFormat,which m

[jira] [Updated] (FLINK-35324) Avro format can not perform projection pushdown for specific fields

2024-05-09 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] SuDewei updated FLINK-35324: Description: AvroFormatFactory.java#createDecodingFormat would return a ProjectableDecodingFormat,which m

[jira] [Commented] (FLINK-33790) Upsert statement filter unique key field colume in mysql dielact

2024-05-14 Thread SuDewei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846487#comment-17846487 ] SuDewei commented on FLINK-33790: - Hi [~jeyhunkarimov] , i think what [~lijingwei.5018]