RE: Race Condition in Streaming Thread

2015-02-27 Thread Nastooh Avessta (navesta)
<http://www.cisco.com/offer/unsubscribe/?sid=000478327> – Privacy<http://www.cisco.com/web/siteassets/legal/privacy.html> From: Tathagata Das [mailto:t...@databricks.com<mailto:t...@databricks.com>] Sent: Friday, February 27, 2015 12:29 PM To: Nastooh Avessta (navesta) Cc: user@spark.apache.

RE: Race Condition in Streaming Thread

2015-02-27 Thread Nastooh Avessta (navesta)
/web/siteassets/legal/privacy.html> From: Tathagata Das [mailto:t...@databricks.com] Sent: Friday, February 27, 2015 12:29 PM To: Nastooh Avessta (navesta) Cc: user@spark.apache.org Subject: Re: Race Condition in Streaming Thread Are you sure the multiple invocations are not from previous runs

Re: Race Condition in Streaming Thread

2015-02-27 Thread Tathagata Das
000478326> - Unsubscribe > <http://www.cisco.com/offer/unsubscribe/?sid=000478327> – Privacy > <http://www.cisco.com/web/siteassets/legal/privacy.html>* > > > > *From:* Tathagata Das [mailto:t...@databricks.com] > *Sent:* Friday, February 27, 2015 12:29 PM &

Re: Race Condition in Streaming Thread

2015-02-27 Thread Tathagata Das
Are you sure the multiple invocations are not from previous runs of the program? TD On Fri, Feb 27, 2015 at 12:16 PM, Nastooh Avessta (navesta) < nave...@cisco.com> wrote: > Hi > > Under Spark 1.0.0, standalone, client mode am trying to invoke a 3rd > party udp traffic generator, from the strea

Race Condition in Streaming Thread

2015-02-27 Thread Nastooh Avessta (navesta)
Hi Under Spark 1.0.0, standalone, client mode am trying to invoke a 3rd party udp traffic generator, from the streaming thread. The excerpt is as follows: ... do{ try { p = Runtime.getRuntime().exec(Prog "); socket.receive(packet);