博主您好，请问下
rdd.mapPartitions(x => {
println("连接数据库")
val res = x.map(line=>{
print("写入数据：" + line)
line
})
res
})
这段代码中为什么不能关闭数据库连接
Spark系列——关于 mapPartitions的误区前言 今天 Review 了一下同事的代码，发现其代码中有非常多的 mapPartitions,问其原因，他说性能比 map 更好。我说为什么性能好呢？于是就有了这篇文章 网...