Re: Lost leader exception in Kafka Direct for Streaming

2015-10-21 Thread Cody Koeninger
n stage 84958.0 failed 4 times, most recent failure: Lost task 15.3 in >>> stage 84958.0 (TID 819461, 10.227.68.102): java.lang.AssertionError: >>> assertion failed: Beginning offset 15027734702 is after the ending >>> offset >>> 15027725493 for topic hubble_strea

Re: Lost leader exception in Kafka Direct for Streaming

2015-10-20 Thread swetha kasireddy
t failure: Lost task 15.3 in >> stage 84958.0 (TID 819461, 10.227.68.102): java.lang.AssertionError: >> assertion failed: Beginning offset 15027734702 is after the ending offset >> 15027725493 for topic hubble_stream partition 12. You either provided an >> invalid fromOffset,

Re: Lost leader exception in Kafka Direct for Streaming

2015-10-01 Thread Adrian Tanase
: swetha Cc: "user@spark.apache.org<mailto:user@spark.apache.org>" Subject: Re: Lost leader exception in Kafka Direct for Streaming Did you check you kafka broker logs to see what was going on during that time? The direct stream will handle normal leader loss / rebalance by retrying

Re: Lost leader exception in Kafka Direct for Streaming

2015-10-01 Thread Cody Koeninger
rtion failed: Beginning offset 15027734702 is after the ending offset > 15027725493 for topic hubble_stream partition 12. You either provided an > invalid fromOffset, or the Kafka topic has been damaged > > > Thanks, > Swetha > > > > > -- > View this message in cont

Lost leader exception in Kafka Direct for Streaming

2015-09-30 Thread swetha
12. You either provided an invalid fromOffset, or the Kafka topic has been damaged Thanks, Swetha -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Lost-leader-exception-in-Kafka-Direct-for-Streaming-tp24891.html Sent from the Apache Spark User List mailing