【Flink】Flink開發中遇到的問題及解法

1. 當Source是Kafka的時候，如何設置Source Operator的併發度？ 如果沒有指定，Source Operator的個數與集羣中的TaskManager的個數相等。如果手動設置，建議使用的slot個數=Kafka Partition的個數／TaskManager的個數。此時，Slot的個數需大於等於2.因爲其中有一個Source Operator。也不建議在一個Slot中啓用多

>>阅读原文<<