Bowen created SPARK-50277:
-----------------------------

             Summary: [k8s] Apply for executor pods in parallel
                 Key: SPARK-50277
                 URL: https://issues.apache.org/jira/browse/SPARK-50277
             Project: Spark
          Issue Type: Improvement
          Components: k8s, Kubernetes
    Affects Versions: 3.5.1
            Reporter: Bowen


The performance of spark on k8s is worse than that of yarn. It is found that 
the application of executor pod is executed sequentially. The k8s interface for 
applying pod is 
kubernetesClient.pods().inNamespace(namespace).resource(podWithAttachedContainer).create(),
 which is asynchronous. However, each execution still takes an average of 
62.57ms. Applying 280 pods takes 17520ms, which means that the speed of 
applying pod is about 15-16 pods/second. If a job requires more executors, this 
speed will become a bottleneck. I would like to ask whether this logic can be 
changed to concurrently apply for executor pods, and whether there will be any 
negative impact.

The logic of applying for executor is in method: 
org.apache.spark.scheduler.cluster.k8s.ExecutorPodsAllocator#requestNewExecutors



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to