RE: Concurrent execution of actions within a driver

2015-10-26 Thread Silvio Fiorito
he.org<mailto:user@spark.apache.org> Subject: Concurrent execution of actions within a driver Does spark run different actions of an rdd within a driver in parallel also? Let's say class Driver{ val rdd1= sc. textFile("... ") val rdd2=sc.textFile("") rdd1. coll

Re: Concurrent execution of actions within a driver

2015-10-26 Thread Rishitesh Mishra
Spark executes tasks on an action. An action is broken down to multiple tasks. Multiple tasks from different actions run either in FIFO or FAIR mode depending on spark.scheduler.mode. Of course to get benefit of FAIR scheduling the two actions should be called by different threads. On Mon, Oct 26,

Re: Concurrent execution of actions within a driver

2015-10-26 Thread Fengdong Yu
not parallel. Spark only execute tasks with Action,(‘collect' here) rdd1.collect and rdd2.collect are executed sequencely, so Spark execute two tasks one by one. > On Oct 26, 2015, at 7:26 PM, praveen S wrote: > > Does spark run different actions of an rdd within a driver in parallel als

Concurrent execution of actions within a driver

2015-10-26 Thread praveen S
Does spark run different actions of an rdd within a driver in parallel also? Let's say class Driver{ val rdd1= sc. textFile("... ") val rdd2=sc.textFile("") rdd1. collect //Action 1 rdd2. collect //Action 2 } Does Spark run Action 1 & 2 run in parallel? ( some kind of a pass through the dri