这个问题的原因应该是你的kafka partition数量应该是大于1的，并且不是所有partition都有数据导致的。 你可以检查下你的kafka topic。 目前来讲，只要你的每个kafka 的partition都有数据，那么watermark应该是可以正常产生的。跟并行度无关。
Asahi Lee <[email protected]> 于2020年9月27日周日 下午6:05写道： > 你好！ > 我使用flink > sql，从kafka中读取数据，然后进行sql聚合操作，然后再输出到kafka中；当我设置并行度为1时，程序执行正常；当我设置并行度为2，甚至更大时；程序可以执行，但是我的kafka中没有看到有数据输出？请问是什么原因呢？ > 使用stream api时，我们可以给每个算子设置并行度，那sql api我们是否可以给每条sql设置并行度？ -- Best, Benchao Li
