Hi ,
I have started a discussion about improving the new TableSource and
TableSink:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-146-Improve-new-TableSource-and-TableSink-interfaces-td45161.html
It includes parallelism setting, welcome to join the discussion and look
Since FLIP-95, the parallelism is decoupled from the runtime class
(DataStream/SourceFunction),
so we need to have an API to tell the planner what the parallelism of the
source/sink is.
This is indeed the purpose of a previous discussion: [DISCUSS] Introduce
SupportsParallelismReport and SupportsS
+1
> -原始邮件-
> 发件人: "Benchao Li"
> 发送时间: 2020-09-20 16:28:20 (星期日)
> 收件人: dev
> 抄送:
> 主题: Re: [DISCUSS] Support source/sink parallelism config in Flink sql
>
> Hi admin,
>
> Thanks for bringing up this discussion.
> IMHO, it's a valuable feature. We also added this feature for our int
