忐忑豆芽

文章
5
资源
0
加入时间
3年1月13天

Spark Streaming foreachRDD以及foreachPartition 操作数据库连接写入数据

Spark Streaming foreachRDD的正确使用误区1. 在driver端创建对象在driver上创建连接对象(比如网络连接或数据库连接)如果在driver上创建连接对象,然后在RDD的算子函数内使用连接对象,那么就意味着需要将连接对象序列化后从driver传递到worker上。而连接对象(比如Connection对象)通常来说是不支持序列化的,此时通常会报序列化的异常(se...