找不到org.apache.spark.streaming.flume.sink.SparkFlumeProtocol$Callback

java.lang.NoClassDefFoundError:org/apache/spark/streaming/flume/sink/SparkFlumeProtocol$Callback
atorg.apache.spark.streaming.flume.FlumePollingReceiver$$anonfun$onStart$1.apply(FlumePollingInputDStream.scala:84)
atorg.apache.spark.streaming.flume.FlumePollingReceiver$$anonfun$onStart$1.apply(FlumePollingInputDStream.scala:82)
atscala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
atscala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34)
atorg.apache.spark.streaming.flume.FlumePollingReceiver.onStart(FlumePollingInputDStream.scala:82)
atorg.apache.spark.streaming.receiver.ReceiverSupervisor.startReceiver(ReceiverSupervisor.scala:148)
atorg.apache.spark.streaming.receiver.ReceiverSupervisor.start(ReceiverSupervisor.scala:130)
atorg.apache.spark.streaming.scheduler.ReceiverTracker$ReceiverTrackerEndpoint$$anonfun$9.apply(ReceiverTracker.scala:542)
atorg.apache.spark.streaming.scheduler.ReceiverTracker$ReceiverTrackerEndpoint$$anonfun$9.apply(ReceiverTracker.scala:532)
atorg.apache.spark.SparkContext$$anonfun$37.apply(SparkContext.scala:1 香港云主机984)
atorg.apache.spark.SparkContext$$anonfun$37.apply(SparkContext.scala:1984)
atorg.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:66)
atorg.apache.spark.scheduler.Task.run(Task.scala:88)
atorg.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:214)
atjava.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
atjava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
atjava.lang.Thread.run(Thread.java:745)
Causedby:java.lang.ClassNotFoundException:org.apache.spark.streaming.flume.sink.SparkFlumeProtocol$Callback
atjava.net.URLClassLoader$1.run(URLClassLoader.java:366)
atjava.net.URLClassLoader$1.run(URLClassLoader.java:355)
atjava.security.AccessController.doPrivileged(NativeMethod)
atjava.net.URLClassLoader.findClass(URLClassLoader.java:354)
atjava.lang.ClassLoader.loadClass(ClassLoader.java:425)
atjava.lang.ClassLoader.loadClass(ClassLoader.java:358)


如果找不到org.apache.spark.streaming.flume.sink.SparkFlumeProtocol$Callback这个类。这个类属于spark-streaming-flume-sink_2.10.jar
org.apache.spark
spark-streaming-flume-sink_2.10
1.5.2

相关推荐: win10系统如何盘查错提升系统性能

这篇文章给大家分享的是有关win10系统如何盘查错提升系统性能的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。1、打开本地磁盘右键菜单，点击“属性”。2、在属性窗口中切换到“工具”标签，点击查错里的“检查”按 香港云主机钮。3、接着在…