spark streaming 有趣問題彙總

1. 關於spark.streaming.concurrent.job參數的問題 1）當參數環境：6個executor，kafka topic 有3個partition，spark.streaming.concurrent.job=1 時 則：只有3個exevutor有task在跑，這個比較好理解，一個executor處理一個分區數據 2）當參數環境：6個executor，kafka topic

>>阅读原文<<