Hi Asahi Lee 你需要确认下kafka topic的分区数是多少，如果是1，那就需要设置下rebalance，让每个tm都有数据流入
Asahi Lee <978466...@qq.com> 于2020年9月27日周日 下午6:05写道： > 你好！ > 我使用flink > sql，从kafka中读取数据，然后进行sql聚合操作，然后再输出到kafka中；当我设置并行度为1时，程序执行正常；当我设置并行度为2，甚至更大时；程序可以执行，但是我的kafka中没有看到有数据输出？请问是什么原因呢？ > 使用stream api时，我们可以给每个算子设置并行度，那sql api我们是否可以给每条sql设置并行度？
