Re: Replaying an RDD in spark streaming to update an accumulator

2015-12-10 Thread Ali Gouta
RAM, BlockManagerId(1, >> slave1.cluster.example, 38959)/ >> >> Any clue on how to resolve this ? Is there a pretty straightforward way >> that >> would allow me updating the values of my userIDs (rather than creating an >> unuseful RDD and pushing it periodic

Re: Replaying an RDD in spark streaming to update an accumulator

2015-12-10 Thread Cody Koeninger
this ? Is there a pretty straightforward way > that > would allow me updating the values of my userIDs (rather than creating an > unuseful RDD and pushing it periodically to the queuestream)? > > > > -- > View this message in context: > h

Replaying an RDD in spark streaming to update an accumulator

2015-12-10 Thread AliGouta
text: http://apache-spark-user-list.1001560.n3.nabble.com/Replaying-an-RDD-in-spark-streaming-to-update-an-accumulator-tp25672.html Sent from the Apache Spark User List mailing list archive at Nabble.com. - To unsubscr