I have one question, how can i create a pyspark code for a single node level task scheduler from a DAGScheduler in python? do you have any mini source code for this? I just wanna try with for single node one task scheuler instead multi node and multi task scheduler from a DAGScheduler?
@tadastadux5 жыл бұрын
Is it possible to do the same using pySpark (not scala)?
@manpreet224u4 жыл бұрын
+1 on the above question. Any thoughts @supergloo?
@itsyashagrawal3 жыл бұрын
+1 on the above question
@saurav07774 жыл бұрын
I have tried to used the fair scheduler but when i checked the stages on spark UI i saw active stages and running tasks in only FIFO scheduler and there is no task and active stages in Fair scheduler...
@Supergloo4 жыл бұрын
how can I repeat?
@saurav07774 жыл бұрын
supergloo you can ignore my ask I have just resolved it by defining spark.scheduler.pool inside the application..thanks for your revert.