;
> intransitive()
> val sparkStreamingFromKafka = "org.apache.spark" %
> "spark-streaming-kafka_2.10" % "0.9.1" excludeAll(
>
>
> -Original Message-
> From: Sean Owen [mailto:so...@cloudera.com]
> Sent: January-22-15 11:39 AM
> To: Adrian M
amingFromKafka = "org.apache.spark" % "spark-streaming-kafka_2.10"
% "0.9.1" excludeAll(
-Original Message-
From: Sean Owen [mailto:so...@cloudera.com]
Sent: January-22-15 11:39 AM
To: Adrian Mocanu
Cc: u...@spark.incubator.apache.org
Subject: Re: Exceptio
ubator.apache.org
Subject: Re: Exception: NoSuchMethodError:
org.apache.spark.streaming.StreamingContext$.toPairDStreamFunctions
NoSuchMethodError almost always means that you have compiled some code against
one version of a library but are running against another. I wonder if you are
including dif
NoSuchMethodError almost always means that you have compiled some code
against one version of a library but are running against another. I
wonder if you are including different versions of Spark in your
project, or running against a cluster on an older version?
On Thu, Jan 22, 2015 at 3:57 PM, Adr
Hi
I get this exception when I run a Spark test case on my local machine:
An exception or error caused a run to abort:
org.apache.spark.streaming.StreamingContext$.toPairDStreamFunctions(Lorg/apache/spark/streaming/dstream/DStream;Lscala/reflect/ClassTag;Lscala/reflect/ClassTag;Lscala/math/Orderi
