pyspark 프로그램은 프로그램 오류 이름을 던지는 '스파크'아래

을 정의되지 않은 정의되지 않은pyspark 프로그램은 프로그램 오류 이름을 던지는 '스파크'아래

Traceback (most recent call last): 
File "pgm_latest.py", line 232, in <module> 
    sconf =SparkConf().set(spark.dynamicAllocation.enabled,true)  
     .set(spark.dynamicAllocation.maxExecutors,300)   
     .set(spark.shuffle.service.enabled,true)  
     .set(spark.shuffle.spill.compress,true) 
NameError: name 'spark' is not defined 
spark-submit --driver-memory 12g --master yarn-cluster --executor-memory 6g --executor-cores 3 pgm_latest.py

코드

#!/usr/bin/python 
import sys 
import os 
from datetime import * 
from time import * 
from pyspark.sql import * 
from pyspark 
import SparkContext 
from pyspark import SparkConf 

sc = SparkContext() 
sqlCtx= HiveContext(sc) 

sqlCtx.sql('SET spark.sql.autoBroadcastJoinThreshold=104857600') 
sqlCtx.sql('SET Tungsten=true') 
sqlCtx.sql('SET spark.sql.shuffle.partitions=500') 
sqlCtx.sql('SET spark.sql.inMemoryColumnarStorage.compressed=true') 
sqlCtx.sql('SET spark.sql.inMemoryColumnarStorage.batchSize=12000') 
sqlCtx.sql('SET spark.sql.parquet.cacheMetadata=true') 
sqlCtx.sql('SET spark.sql.parquet.filterPushdown=true') 
sqlCtx.sql('SET spark.sql.hive.convertMetastoreParquet=true') 
sqlCtx.sql('SET spark.sql.parquet.binaryAsString=true') 
sqlCtx.sql('SET spark.sql.parquet.compression.codec=snappy') 
sqlCtx.sql('SET spark.sql.hive.convertMetastoreParquet=true') 

## Main functionality 
def main(sc): 

    if name == 'main': 

     # Configure OPTIONS 
     sconf =SparkConf() \ 
      .set("spark.dynamicAllocation.enabled","true")\ 
      .set("spark.dynamicAllocation.maxExecutors",300)\ 
      .set("spark.shuffle.service.enabled","true")\ 
      .set("spark.shuffle.spill.compress","true") 

sc =SparkContext(conf=sconf) 

# Execute Main functionality 

main(sc) 
sc.stop()

출처

2016-07-15 Satish Kumar Reddy

다음이