Re: jars are not loading from 1.3. those set via setJars to the SparkContext

2015-06-23 Thread Murthy Chelankuri
gt; On Mon, Jun 22, 2015 at 11:50 PM, Murthy Chelankuri > wrote: > >> I am invoking it from the java application by creating the sparkcontext >> >> On Tue, Jun 23, 2015 at 12:17 PM, Tathagata Das >> wrote: >> >>> How are you adding that to the classpat

Re: jars are not loading from 1.3. those set via setJars to the SparkContext

2015-06-22 Thread Murthy Chelankuri
I am invoking it from the java application by creating the sparkcontext On Tue, Jun 23, 2015 at 12:17 PM, Tathagata Das wrote: > How are you adding that to the classpath? Through spark-submit or > otherwise? > > On Mon, Jun 22, 2015 at 5:02 PM, Murthy Chelankuri > wrote: >

Re: jars are not loading from 1.3. those set via setJars to the SparkContext

2015-06-22 Thread Murthy Chelankuri
one or local. These > details will be very useful. > >> On Mon, Jun 22, 2015 at 8:34 AM, Murthy Chelankuri >> wrote: >> I am using spark streaming. what i am trying to do is sending few messages >> to some kafka topic. where its failing. >> >> java.lan

Re: jars are not loading from 1.3. those set via setJars to the SparkContext

2015-06-22 Thread Murthy Chelankuri
kafka.producer.Producer.(Producer.scala:61) On Mon, Jun 22, 2015 at 8:24 PM, Murthy Chelankuri wrote: > I have been using the spark from the last 6 months with the version 1.2.0. > > I am trying to migrate to the 1.3.0 but the same problem i have written is > not wokring. > > It

jars are not loading from 1.3. those set via setJars to the SparkContext

2015-06-22 Thread Murthy Chelankuri
all the dependent jars array to the spark context but not working in 1.3.0 Please help me how to resolve this. Thanks, Murthy Chelankuri

Getting erorrs in spark worker nodes

2014-09-30 Thread Murthy Chelankuri
I am new to the spark. I am trying to implement the spark streaming from the kafka topic. It worked fine for some time. but some time later it started throwing the below error. I am not getting any clue what causing the issues. java.lang.Exception: Could not compute split, block input-0-141204598