通过Yarn提交Application模式的job TaskManager无法输出日志

at akka.dispatch.Mailbox.run(Mailbox.scala:225) ~[akka-actor_2.11-2.5.21.jar:2.5.21] at akka.dispatch.Mailbox.exec(Mailbox.scala:235) ~[akka-actor_2.11-2.5.21.jar:2.5.21] ... 4 more [email protected]

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

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