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
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
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
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