问使用火花流从http创建分析

EN

嗨，我的reqmnt是从http://10.3.9.34:9900/messages创建分析，即从http://10.3.9.34:9900/messages中提取数据，并将这些数据放在HDFS /user/cloudera/flume和HDFS报告中，使用Tableau或HUE UI。我在code 5.5的星火壳的scala控制台尝试了下面的代码，但是无法从http链接中获取数据。

import org.apache.spark.SparkContext
val dataRDD = sc.textFile("http://10.3.9.34:9900/messages")
dataRDD.collect().foreach(println)
dataRDD.count()
dataRDD.saveAsTextFile("/user/cloudera/flume")

我在scala控制台获得了以下错误：

org.apache.hadoop.fs.FileSystem.getFileSystemClass(FileSystem.java:2623) at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:2637) at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:93) at org.apache.hadoop.fs.FileSystem$Cache.getInternal(FileSystem.java:2680) at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:2662) at org.apache.hadooporg.apache.hadoop.fs.Path.getFileSystem(Path.java:296) .fs.FileSystem.get(FileSystem.java:379)