print CLUSTER_URL

from pyspark import  SparkContext
sc = SarkContext( CLUSTER_URL, 'pyspark')

sc.parallelize([1,2,3])