可以参考 https://blog.csdn.net/weixin_41608066/article/details/108557869。“目前flink
sql是不支持source/sink并行度配置的,flink sql中各算子并行度默认是根据source的partition数或文件数来决定。”
如果想实现在设置 source 时指定并行度,可以参考该文章对源码做些修改。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复