启动spark streaming失败,报错为:
原因: java.lang.NoClassDefFoundError: org/apache/spark/api/java/function/FlatMapFunction
解决:
在pom.xml里面,原配置
org.apache.spark spark-streaming_2.123.2.1 provided
的
provided
删掉即可。变为:
org.apache.spark spark-streaming_2.123.2.1

启动spark streaming失败,报错为:
原因: java.lang.NoClassDefFoundError: org/apache/spark/api/java/function/FlatMapFunction
解决:
在pom.xml里面,原配置
org.apache.spark spark-streaming_2.123.2.1 provided
的
provided
删掉即可。变为:
org.apache.spark spark-streaming_2.123.2.1