您的s3_client不可序列化。
代替flatMap使用mapPartitions,并在lambda主体内部初始化s3_client以避免开销。那将:
上一篇 使用python和postgres,execute函数中的变量?
下一篇 Python文件索引和搜索
版权所有 (c)2021-2022 MSHXW.COM
ICP备案号:晋ICP备2021003244-6号