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

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

>>阅读原文<<