#NEWLINE# def _create_hadoop_spark_dirs( self , cluster_context ) : #NEWLINE# #INDENT# path = '/apps/spark' #NEWLINE# run_as_user = 'mapr' #NEWLINE# with cluster_context . get_instance ( SPARK_MASTER ) . remote ( ) as r : #NEWLINE# #INDENT# mfs . mkdir ( r , path , run_as = run_as_user ) #NEWLINE# mfs . chmod ( r , cluster_context , 777 , run_as = run_as_user )