【发布时间】:2019-08-12 12:16:20
【问题描述】:
我正在尝试使用以下代码通过 pyspark 访问我在 hdfs 中的文件:
spark = SparkSession.builder.appName("MongoDBIntegration").getOrCreate()
receipt = spark.read.json("hdfs:///bigdata/2.json")
我得到一个错误Incomplete HDFS URI, no host: hdfs:///bigdata/2.json
但如果我写命令 hdfs dfs -cat /bigdata/1.json 它会打印我的文件
【问题讨论】:
标签: apache-spark hadoop pyspark hdfs hdp