【Flink】Flink开发中遇到的问题及解法

1. 当Source是Kafka的时候，如何设置Source Operator的并发度？ 如果没有指定，Source Operator的个数与集群中的TaskManager的个数相等。如果手动设置，建议使用的slot个数=Kafka Partition的个数／TaskManager的个数。此时，Slot的个数需大于等于2.因为其中有一个Source Operator。也不建议在一个Slot中启用多

>>阅读原文<<