File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -241,7 +241,7 @@ echo "SPARK_MASTER_URL: ${SPARK_MASTER_URL}"
241241echo  " SPARK_MASTER_WEBUI: ${SPARK_MASTER_WEBUI} " 
242242
243243#  Create a worker starter script for non-daemonized spark workers.
244- cat >  ${SCRATCH}  /tmp /sparkworker.sh << EOF 
244+ cat >  ${SPARK_CONF_DIR}  /sparkworker.sh << EOF 
245245#!/bin/bash 
246246ulimit -u 16384 -n 16384 
247247export SPARK_CONF_DIR=${SPARK_CONF_DIR}  
@@ -252,10 +252,10 @@ exec spark-class org.apache.spark.deploy.worker.Worker "${SPARK_MASTER_URL}" &>
252252EOF 
253253
254254#  Broadcast the worker script to all slurm nodes.
255- chmod +x ${SCRATCH}  /tmp /sparkworker.sh
256- sbcast  ${SCRATCH} /tmp /sparkworker.sh " ${SCRATCH} /sparkworker.sh"   \
255+ chmod +x ${SPARK_CONF_DIR}  /sparkworker.sh
256+ srun cp  ${SPARK_CONF_DIR} /sparkworker.sh " ${SCRATCH} /sparkworker.sh"   \
257257    ||  fail " Could not broadcast worker start script to nodes" 
258- rm -f ${SCRATCH}  /tmp /sparkworker.sh
258+ rm -f ${SPARK_CONF_DIR}  /sparkworker.sh
259259
260260#  Modify the worker script on the node that will run the spark driver. Reduce
261261#  the resources requested by the worker to leave resources for the driver.
    
 
   
 
     
   
   
          
     
  
    
     
 
    
      
     
 
     
    You can’t perform that action at this time.
  
 
    
  
     
    
      
        
     
 
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments