diff --git a/3-1.py b/3-1.py index bf31c98..6424816 100644 --- a/3-1.py +++ b/3-1.py @@ -10,7 +10,7 @@ def tokenize(text): def load_stopwords(sc): try: - return set(sc.textFile("hdfs:///user/root/stopwords.txt").collect()) + return set(sc.textFile("hdfs://master:9000/user/root/stopwords.txt").collect()) except: # fallback to local with open("stopwords.txt", "r") as f: