|
@@ -32,7 +32,7 @@ logger = logging.getLogger(__name__)
|
|
|
|
|
|
hadoop_home = "/opt/apps/HADOOP-COMMON/hadoop-common-current/" # Hadoop 安装目录
|
|
|
configs = {
|
|
|
- "fs.default.name": "hdfs://192.168.141.208:8020", # HDFS 名称和端口
|
|
|
+ "fs.default.name": "hdfs://192.168.141.208:9000", # HDFS 名称和端口
|
|
|
"hadoop.job.ugi": "" # HDFS 用户和密码
|
|
|
}
|
|
|
hdfs_client = HDFSClient(hadoop_home, configs)
|