找了好久,才偶然看到这样一篇救命的文章
http://qnalist.com/questions/5001816/which-is-the-best-way-to-get-a-connection-to-an-external-database-per-task-in-spark-streaming
我们可以不使用
ssc.sparkContext.broadcast(pool)
而是使用单例模式即可
找了好久,才偶然看到这样一篇救命的文章
http://qnalist.com/questions/5001816/which-is-the-best-way-to-get-a-connection-to-an-external-database-per-task-in-spark-streaming
我们可以不使用
ssc.sparkContext.broadcast(pool)
而是使用单例模式即可