2.0.0.rar之sparkstreamingflumesink_2.112.0.0.jar
flume与sparkstreaming结合(pull方式)报错:org.apache.flume.FlumeException:Unabletoloadsinktype:org.apache.spark.streaming.flume.sink.SparkSink,class:org.apache.spark.streaming.flume.sink.SparkSink;
把spark-streaming-flume-sink_2.11-2.2.0.jar复制到flume的lib目录。(使用不同版本的scala和spark请放对应的jar)我这里使用的scala为2.11.
用户评论