You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "xiaozhennan1995@gmail.com" <xi...@gmail.com> on 2020/07/10 06:27:51 UTC

Flink自定义Source 抽取Mysql多张表,并行抽取可以实现吗?

场景: 同时每隔30s 抽取N张Mysql的数据表,根据时间字段抽取
自定义的Source 能否通过设置Source的并行度  比如有十张表,设置并行度为3   根据并行度动态分配抽取的表 类似根据并行度和kafka的分区的关系
在一个source里,所有数据混合一起发往下游



xiaozhennan1995@gmail.com