Re: StreamingListener, anyone?

2015-06-04 Thread Dmitry Goldenberg
job has been >> stopped."); >> } >> >> >> I do not seem to be seeing onBatchCompleted being triggered. Am I doing >> something wrong? >> >> In this particular case, I was trying to implement a bulk ingest t

Re: StreamingListener, anyone?

2015-06-04 Thread Shixiong Zhu
articular case, I was trying to implement a bulk ingest type of > logic where the first batch is all we're interested in (reading out of a > Kafka topic with offset reset set to "smallest"). > > > > > -- > View this message

Re: StreamingListener, anyone?

2015-06-04 Thread Akhil Das
we're interested in (reading out of a > Kafka topic with offset reset set to "smallest"). > > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/StreamingListener-anyone-tp23140.html > Sent from the Apache Spark Us

StreamingListener, anyone?

2015-06-03 Thread dgoldenberg
nterested in (reading out of a Kafka topic with offset reset set to "smallest"). -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/StreamingListener-anyone-tp23140.html Sent from the Apach