PySpark报错:'NoneType'对象无selectExpr属性,求排查解决
AttributeError报错:PySpark代码运行时出现未定义属性问题
我运行以下PySpark代码时触发了AttributeError:
sel = spark_df.selectExpr("CAST(value AS STRING)") \ .select(from_json(col('value'), schema).alias('data')).select("data.*") print(sel) return sel
环境与前置情况
- 开发环境:WSL + VSCode,未预先配置完整PySpark环境,遇到错误后才逐步安装相关依赖
- 此前曾因缺少
spark-cassandra-connector和spark-sql-kafka的.jar文件触发Java错误,已手动下载对应文件放入PySpark的jars子目录,但仍出现上述AttributeError
内容的提问来源于stack exchange,提问作者Mithil Bartakke
相关产品推荐
相关产品推荐

