fix(3-1): 更新 HDFS 地址

- 将 HDFS 地址从 "hdfs:///user/root/output/inverted_index" 修改为 "hdfs://master:9000/user/root/output/inverted_index"
- 这个修改可能是为了适应不同的 HDFS集群配置,确保数据保存到正确的地址
This commit is contained in:
fly6516 2025-04-16 09:46:39 +08:00
parent 4c79cad322
commit ceaf470df4

2
3-1.py
View File

@ -61,6 +61,6 @@ if __name__ == "__main__":
.mapValues(lambda ids: list(set(ids)))
# 输出(可保存到 HDFS
inverted_index.saveAsTextFile("hdfs:///user/root/output/inverted_index")
inverted_index.saveAsTextFile("hdfs://master:9000/user/root/output/inverted_index")
sc.stop()