|
@@ -30,7 +30,7 @@ logging.basicConfig(
|
|
|
format='%(asctime)s - %(levelname)s - %(message)s', level=logging.INFO)
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
-hadoop_home = "/opt/apps/HADOOP-COMMON/hadoop-common-current" # Hadoop 安装目录
|
|
|
+hadoop_home = "/app/env/hadoop-3.2.4" # Hadoop 安装目录
|
|
|
configs = {
|
|
|
"fs.default.name": "hdfs://192.168.141.208:9000", # HDFS 名称和端口
|
|
|
"hadoop.job.ugi": "" # HDFS 用户和密码
|