我使用pydoopapi的Python代码如下所示。我有一个文本文件/home/progen/test.txt
。当运行脚本将此文件复制到HDFS时,我得到一个错误。在
import pydoop.hdfs as hdfs
local_path = '/home/progen/test.txt'
hdfs_path = '/spark_user/'
host = 'master'
port = 9000
hdfsobj = hdfs.hdfs(host, port, user='spark', groups=['supergroup'])
hdfsobj.copy(local_path, hdfsobj, hdfs_path)
目前没有回答
相关问题 更多 >
编程相关推荐