Gracefully stopping a Spark Streaming application

2014-10-17 Thread Massimiliano Tomassi
mming-guide.html#deploying-applications Question is: how can I call StreamingContext.stop(...) <http://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.streaming.StreamingContext> from outside the application? Thanks a lot, Max -- ---- M

Re: Spark Streaming Fault Tolerance (?)

2014-10-09 Thread Massimiliano Tomassi
t for your help Max On 7 October 2014 18:17, Massimiliano Tomassi wrote: > Reading the Spark Streaming Programming Guide I found a couple of > interesting points. First of all, while talking about receivers, it says: > > *"If the number of cores allocated to the application is less

Spark Streaming Fault Tolerance (?)

2014-10-07 Thread Massimiliano Tomassi
ic to get right. Thanks a lot, Max -- -------- Massimiliano Tomassi web: http://about.me/maxtomassi e-mail: max.toma...@gmail.com

Re: Dstream Transformations

2014-10-06 Thread Massimiliano Tomassi
essage. >> >> --------- >> To unsubscribe, e-mail: user-unsubscr...@spark.apache.org >> For additional commands, e-mail: user-h...@spark.apache.org >> >> > -- Massimiliano Tomassi web: http://about.me/maxtomassi e-mail: max.toma...@gmail.com

Publishing a transformed DStream to Kafka

2014-09-02 Thread Massimiliano Tomassi
nks a lot, Max -- Massimiliano Tomassi e-mail: max.toma...@gmail.com