from pyspark.sql import SparkSession
spark = SparkSession.builder \
.appName('Cloudera Sample Job') \
.master('yarn') \
.config('spark.hadoop.fs.defaultFS','hdfs://192.168.56.172:8020') \
.config('spark.hadoop.yarn.resourcemanager.address','
192.168.56.172:8032') \
.getOrCreate()
print ("--------Hello Wordld------------")