【求助】sparksql向mongo加载数据的时候出现了下面一个报错

Df.write.save()用这个save方法将数据存入数据库的时候就会报这个错，但是我的项目里根本没有result这个字段，完全无从下手这个bug，还有下面的信息像是一段代码文件也不知道是什么，急，求各位大神救救，可有偿

Data source在哪里？建议你先show一下你读取的数据，看看是哪个环节的问题，光看这个报错不太看得出来。但是你可以尝试手动设置下StructField来试试看，直接先写入其中几个字段试试，看看有没有问题。如果没问题，说明不是你save算子这里的错误。

不感兴趣

开通SVIP免广告

还有一种可能，我之前遇到过的读取json数据的时候，因为嵌套json的问题导致的是你这种类似的错误(字段重复类error)，所以你也可以检查下你读取数据源的字段看看，是不是有些需要你手动处理下或者自己设置下schema更严谨

下载贴吧APP
看高清直播、视频！

分享到: