I am assuming that you are referring to the "OneForOneStrategy: key not found: 1401753992000 ms" error, and not to the previous "Time 1401753992000 ms is invalid ...". Those two seem a little unrelated to me. Can you give us the stacktrace associated with the key-not-found error?
TD On Mon, Jun 2, 2014 at 5:22 PM, Vadim Chekan <kot.bege...@gmail.com> wrote: > Hi all, > > I am getting an error: > ================ > 14/06/02 17:06:32 INFO WindowedDStream: Time 1401753992000 ms is invalid > as zeroTime is 1401753986000 ms and slideDuration is 4000 ms and difference > is 6000 ms > 14/06/02 17:06:32 ERROR OneForOneStrategy: key not found: 1401753992000 ms > ================ > > My relevant code is: > =================== > ssc = new StreamingContext(conf, Seconds(1)) > val messageEvents = events. > flatMap(e => evaluatorCached.value.find(e)). > window(Seconds(8), Seconds(4)) > messageEvents.print() > =================== > > Seems all right to me, window slide duration (4) is streaming context > batch duration (1) *2. So, what's the problem? > > Spark-v1.0.0 > > -- > From RFC 2631: In ASN.1, EXPLICIT tagging is implicit unless IMPLICIT is > explicitly specified >
