[jira] [Commented] (FLINK-25582) flink sql kafka source cannot special custom parallelism
[ https://issues.apache.org/jira/browse/FLINK-25582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644704#comment-17644704 ] Yufei Zhang commented on FLINK-25582: - I currently use `table.exec.resource.default-parallelism` to set the sql source parallelism. But still it would be nice to set the source parallelism explicitly. > flink sql kafka source cannot special custom parallelism > > > Key: FLINK-25582 > URL: https://issues.apache.org/jira/browse/FLINK-25582 > Project: Flink > Issue Type: Improvement > Components: Connectors / Kafka, Table SQL / API >Affects Versions: 1.13.0, 1.14.0 >Reporter: venn wu >Priority: Not a Priority > Labels: auto-deprioritized-minor, pull-request-available > > when use flink sql api, all operator have same parallelism, but in some times > we want specify the source / sink parallelism for kafka source, i noticed the > kafka sink already have parameter "sink.parallelism" to specify the sink > parallelism, but kafka source no, so we want flink sql api, have a parameter > to specify the kafka source parallelism like sink. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Commented] (FLINK-25582) flink sql kafka source cannot special custom parallelism
[ https://issues.apache.org/jira/browse/FLINK-25582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474331#comment-17474331 ] venn wu commented on FLINK-25582: - [~MartijnVisser] thanks for reminding, i have add the describe for the issure, please check again > flink sql kafka source cannot special custom parallelism > > > Key: FLINK-25582 > URL: https://issues.apache.org/jira/browse/FLINK-25582 > Project: Flink > Issue Type: Improvement > Components: Connectors / Kafka, Table SQL / API >Affects Versions: 1.13.0, 1.14.0 >Reporter: venn wu >Priority: Minor > Labels: pull-request-available > > when use flink sql api, all operator have same parallelism, but in some times > we want specify the source / sink parallelism for kafka source, i noticed the > kafka sink already have parameter "sink.parallelism" to specify the sink > parallelism, but kafka source no, so we want flink sql api, have a parameter > to specify the kafka source parallelism like sink. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-25582) flink sql kafka source cannot special custom parallelism
[ https://issues.apache.org/jira/browse/FLINK-25582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17473105#comment-17473105 ] Martijn Visser commented on FLINK-25582: [~wxchunj...@163.com] Can you please first explain in the ticket what is the problem you're trying to solve? We should first understand this and then agree that this should indeed end up in Flink before opening a PR. > flink sql kafka source cannot special custom parallelism > > > Key: FLINK-25582 > URL: https://issues.apache.org/jira/browse/FLINK-25582 > Project: Flink > Issue Type: Improvement > Components: Connectors / Kafka, Table SQL / API >Affects Versions: 1.13.0, 1.14.0 >Reporter: venn wu >Priority: Minor > Labels: pull-request-available > > costom flink sql kafka source parallelism -- This message was sent by Atlassian Jira (v8.20.1#820001)
