diff --git a/3-1.py b/3-1.py index 48a8157..c8f5062 100644 --- a/3-1.py +++ b/3-1.py @@ -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()