RE: Concurrent execution of actions within a driver

[Silvio Fiorito]

There is a collectAsync action if you want to run them in parallel, but keep in 
mind the two jobs will need to share resources and you should use the FAIR 
scheduler.

From: praveen S
Sent: ‎10/‎26/‎2015 4:27 AM
To: 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. collect //Action 1
rdd2. collect //Action 2

}

Does Spark run Action 1 & 2 run in parallel? ( some kind of a pass through the 
driver code and than start the execution)?

if not than is using threads safe for independent actions/red's?

Re: Concurrent execution of actions within a driver

[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, 2015 at 5:01 PM, Fengdong Yu 
wrote:

> 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
> 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 driver code and than start the execution)?
>
> if not than is using threads safe for independent actions/red's?
>
>
>


-- 

Regards,
Rishitesh Mishra,
SnappyData . (http://www.snappydata.io/)

https://in.linkedin.com/in/rishiteshmishra

Re: Concurrent execution of actions within a driver

[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 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 driver code and than start the execution)?
> 
> if not than is using threads safe for independent actions/red's?
>