想获取到的话其实可以通过 REST API 去如下图的 metrics 处获取作业 source 往下 send 的数据量和速度，不过这个是单个并行度的，可以去将每个并行度的累加起来。
http://zhisheng-blog.oss-cn-hangzhou.aliyuncs.com/2020-10-14-060508.png [image: image.png] Best zhisheng Kevin Liu <[email protected]> 于2020年10月14日周三 上午12:35写道： > 可以参考 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/
