bq. its Spark libs are all at 2.10
Clarification: 2.10 is version of Scala
Your Spark version is 1.1.0
You can use earlier release of Kafka.
Cheers
On Mon, May 4, 2015 at 2:39 PM, Eric Ho wrote:
> I still prefer to use Spark core / streaming /... at 2.10 becuase my DSE
> is at 4.6.1 and its S
Looks like you're using Spark 1.1.0
Support for Kafka 0.8.2 was added by:
https://issues.apache.org/jira/browse/SPARK-2808
which would come in Spark 1.4.0
FYI
On Mon, May 4, 2015 at 12:22 PM, Eric Ho wrote:
> I'm submitting this via 'dse spark-submit' but somehow, I don't see any
> loggings i
I'm submitting this via 'dse spark-submit' but somehow, I don't see any
loggings in my cluster or worker machines...
How can I find out ?
My cluster is running DSE 4.6.1 with Spark enabled.
My source is running Kafka 0.8.2.0
I'm launching my program on one of my DSE machines.
Any insights much