当我尝试时,我已经在hadoop中有服务器的csv文件

hdfs = pyhdfs.HdfsClient(hosts='34.71.193.160:8123', user_name='root')

files_name = hdfs.listdir('/user/input/')

收到此错误消息,找不到解决方法
HdfsException: Expected JSON. Is WebHDFS enabled? Got ''

最佳答案



Spark可以直接从NameNode读取。不要使用WebHDFS

例如逐行读取目录中的所有文件

df = spark.read.csv("/user/input")
df.show()

关于python - Hadoop获得了Expected JSON。是否启用了WebHDFS?得到了 '',我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/61299608/

10-10 17:00