我收到以下错误：
在sun.reflect的SampleStream.main（NetworkWordCount.scala）处的线程“main”java.lang.NoClassDefFoundError：org / apache / spark / streaming / flume / FlumeUtils $处于SampleStream $ .main（NetworkWordCount.scala：10）处的异常at.MativeMethodAccessorImpl.invoke0（Native Method）at sun.reflect.NativeMethodAccessorImpl.invoke（NativeMethodAccessorImpl.java:57）at sun.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMethodAccessorImpl.java:43）at java.lang.reflect.Method.invoke（Method .java：606）org.apache.spark.deploy.SparkSubmit $ .org $ apache $ spark $ deploy $ SparkSubmit $$ runMain（SparkSubmit.scala：665）at org.apache.spark.deploy.SparkSubmit $ .doRunMain $ 1 （SparkSubmit.scala：170）org.apache.spark.deploy.SparkSubmit $ .submit（SparkSubmit.scala：193）atg.apache.spark.deploy.SparkSubmit $ .main（SparkSubmit.scala：112）at org . apache.spark.deploy.SparkSubmit.main（SparkSubmit.scala）引起：java.lang.ClassNotFoundException：org.apache.spark.streaming.flume.FlumeUtils $ at java.net.URLClassLoader $ 1.run（URLClass） Loader.java:366）java.net.URLClassLoader $ 1.run（URLClassLoader.java:355）at java.security.AccessController.doPrivileged（Native Method）at java.net.URLClassLoader.findClass（URLClassLoader.java:354）at at java.lang.ClassLoader.loadClass（ClassLoader.java:425）java.lang.ClassLoader.loadClass（ClassLoader.java:358）
我在下面链接
https://spark.apache.org/docs/1.4.1/streaming-flume-integration.html
2 回答
您需要将spark-streaming-flume及其依赖项（spark-core和spark-streaming，由spark-submit提供）打包到应用程序JAR中 .
https://spark.apache.org/docs/1.6.1/streaming-flume-integration.html有关于部署的更好描述 . 您可以使用此文档，因为1.4和1.6之间没有API更改 .
您需要在类路径中加载所有库 . 将其添加到build.sbt文件：
libraryDependencies += "org.apache.spark" % "spark-streaming-flume_2.10" % "1.6.1"