我在执行本地文件时报这个错

来源:7-7 -案例实战之Spark Streaming处理文件系统数据

WaniuZhang_ITBoy

2019-12-22

Time: 1576945495000 ms

19/12/22 00:25:00 WARN dstream.FileInputDStream: Error finding new files
java.lang.NullPointerException
at scala.collection.mutable.ArrayOpsofRefofRefofRef.length$extension(ArrayOps.scala:192)

写回答

1回答

Michael_PK

2019-12-22

上下文以及代码描述下

0
2
Michael_PK
回复
WaniuZhang_ITBoy
是的,必须是启动后放到目录下的文件,而且文件的编辑时间是要在启动后,不然不会读取数据的
2019-12-24
共2条回复

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

查看课程