diff --git a/2-9.py b/2-9.py index 454ca96..7b1cd95 100644 --- a/2-9.py +++ b/2-9.py @@ -49,7 +49,7 @@ def main(): .getOrCreate() # 读取日志文件 - logFile = 'apache.access.log.PROJECT' # 替换为您的日志文件路径 + logFile = 'hdfs://master:9000/user/root/apache.access.log.PROJECT' rdd = spark.sparkContext.textFile(logFile) # 解析日志行