I am not sure if your issue is setting the Fair mode correctly or something
else so let's start with the FAIR mode.
Do you see scheduler mode actually being set to FAIR:
I have this line in spark-defaults.conf
spark.scheduler.allocation.file=/spark/conf/fairscheduler.xml
Then, when I start my ap
Hi Yana,
I tried running the program after setting the property
"spark.scheduler.mode" to FAIR. But the result is same as previous. Are
there any other properties that have to be set?
On Tue, Feb 24, 2015 at 10:26 PM, Yana Kadiyska
wrote:
> It's hard to tell. I have not run this on EC2 but thi
It's hard to tell. I have not run this on EC2 but this worked for me:
The only thing that I can think of is that the scheduling mode is set to
- *Scheduling Mode:* FAIR
val pool: ExecutorService = Executors.newFixedThreadPool(poolSize)
while_loop to get curr_job
pool.execute(new ReportJ