File tree Expand file tree Collapse file tree 1 file changed +10
-6
lines changed Expand file tree Collapse file tree 1 file changed +10
-6
lines changed Original file line number Diff line number Diff line change @@ -544,18 +544,22 @@ Please note that the [Delta Lake](https://delta.io/) packages are only available
544544``` dockerfile 
545545FROM  jupyter/pyspark-notebook:latest
546546
547- ARG  DELTA_CORE_VERSION="0.8.0" 
547+ ARG  DELTA_CORE_VERSION="1.0.0" 
548+ RUN  pip install --quiet --no-cache-dir delta-spark==${DELTA_CORE_VERSION} && \
549+      fix-permissions "${HOME}"  && \
550+      fix-permissions "${CONDA_DIR}" 
548551
549552USER  root
550553
551- RUN  echo "spark.jars.packages io.delta:delta-core_2.12:${DELTA_CORE_VERSION}"  >> $SPARK_HOME/conf/spark-defaults.conf && \
552-     echo 'spark.sql.extensions io.delta.sql.DeltaSparkSessionExtension'  >> $SPARK_HOME/conf/spark-defaults.conf && \
554+ RUN  echo 'spark.sql.extensions io.delta.sql.DeltaSparkSessionExtension'  >> $SPARK_HOME/conf/spark-defaults.conf && \
553555    echo 'spark.sql.catalog.spark_catalog org.apache.spark.sql.delta.catalog.DeltaCatalog'  >> $SPARK_HOME/conf/spark-defaults.conf
554556
555557USER  $NB_UID
556558
557- #  Run pyspark and exit to trigger the download of the delta lake jars
558- RUN  echo "quit()"  > /tmp/init-delta.py && \
559-     spark-submit /tmp/init-delta.py && \
559+ #  Trigger download of delta lake files
560+ RUN  echo "from pyspark.sql import SparkSession"  > /tmp/init-delta.py && \
561+     echo "from delta import *"  >> /tmp/init-delta.py && \
562+     echo "spark = configure_spark_with_delta_pip(SparkSession.builder).getOrCreate()"  >> /tmp/init-delta.py && \
563+     python /tmp/init-delta.py && \
560564    rm /tmp/init-delta.py
561565``` 
 
 
   
 
     
   
   
          
    
    
     
    
      
     
     
    You can’t perform that action at this time.
  
 
    
  
    
      
        
     
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments