出错原因是写spark任务时调用了返回值中包含了numpy.dtype类型的值,需要转为通用的float类型即可

 

参考链接http://tech.dianwoda/2018/01/31/net-razorvine-pickle-pickleexception-expected-zero-arguments-for-construction-of-classdict-for-numpy-dtype/

更多推荐

PickleException: expected zero arguments for construction of ClassDict (for nump