#NEWLINE# def _get_spark_ha_props( self , cluster_context ) : #NEWLINE# #INDENT# zookeepers = cluster_context . get_zookeeper_nodes_ip_with_port ( ) #NEWLINE# login_conf = ( '%s/conf/mapr.login.conf' % cluster_context . mapr_home ) #NEWLINE# props = { #NEWLINE# #INDENT# 'spark.deploy.recoveryMode' : 'ZOOKEEPER' , #NEWLINE# 'spark.deploy.zookeeper.url' : zookeepers , #NEWLINE# 'zookeeper.sasl.client' : 'false' , #NEWLINE# 'java.security.auth.login.config' : login_conf , #NEWLINE# #UNINDENT# } #NEWLINE# props = ' ' . join ( map ( ( lambda i : ( '-D%s=%s' % i ) ) , six . iteritems ( props ) ) ) #NEWLINE# return { #NEWLINE# #INDENT# 'SPARK_DAEMON_JAVA_OPTS' : props , #NEWLINE# #UNINDENT# }