[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822472#comment-17822472
]
yuanfenghu commented on FLINK-34535:
------------------------------------
Hi [~jeyhunkarimov]
谢谢你的评论，其实我的想法很简单，我希望在使用 flink sql 时, sql-client or
sql-gateway,生成的flink任务中我能有办法能单独设置我每个 vertex的并行度
比如我现在有个简单的任务生成的jobgraph是:
-> window1 -> sink1
KAFKA SOURCE -> window2 -> sink2
-> window3 -> sink3
In flinksql, I can set the parallelism of the entire job through set
parallelism.default=x, but if I want to set the parallelism of each vertex, I
cannot do it.
所以我如果通过explain语法拿到整个任务的jobgraph信息:
-> window1(id2) -> sink1(id5)
KAFKA SOURCE(id1) -> window2(id3) -> sink2(id6)
-> window3(id4) -> sink3(id7)
配合参数: pipeline.jobvertex-parallelism-overrides
> Support JobPlanInfo for the explain result
> ------------------------------------------
>
> Key: FLINK-34535
> URL: https://issues.apache.org/jira/browse/FLINK-34535
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / Planner
> Reporter: yuanfenghu
> Priority: Major
> Labels: pull-request-available
>
> In the Flink Sql Explain syntax, we can set ExplainDetails to plan
> JSON_EXECUTION_PLAN, but we cannot plan JobPlanInfo. If we can explain this
> part of the information, referring to JobPlanInfo, I can combine it with the
> parameter `pipeline.jobvertex-parallelism-overrides` to set up my task
> parallelism
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
