假设您使用的是基于linux的操作系统，则可能需要提供本地文件系统中安装数据目录的位置的完整路径。例如

val movieLensHomeDir = "file:///Users/user/training-downloads/data/movielens/medium"
sc.textFile(movieLensHomeDir, "ratings.dat")

将此与hdfs进行比较，在hdfs中，您可能能够给出hdfs中的路径，而不是本地文件系统。

val movieLensHomeDir = "/data/movielens/medium"
sc.textFile(movieLensHomeDir, "ratings.dat")

或者如spark文档所示：
要从spark访问hadoop数据，只需使用hdfs://url（通常是hdfs://:9000/path，但您可以在hadoop namenode的web ui上找到正确的url）。

val movieLensHomeDir = "hdfs://<namenode>:9000/data/movielens/medium"
sc.textFile(movieLensHomeDir, "ratings.dat")

试试这个

//this is your input path
val text_file = sc.textFile("hdfs://...")
//or 
val text_file = sc.textFile("your local path") 

//mapping and reduscing 
val counts = textFile.flatMap(line => line.split(" ")).map(word => (word, 1)).reduceByKey(_ + _)

//output path
counts.saveAsTextFile("hdfs://...") or
counts.saveAsTextFile("your local file system path")