#NEWLINE# def __init__( self , cluster_dict , cluster_name ) : #NEWLINE# #INDENT# ServiceConfig . parse_params ( self , 'cluster' , cluster_dict , CLUSTER_SCHEMA ) #NEWLINE# self . jobs = self . jobs . split ( ) #NEWLINE# if ( self . name != cluster_name ) : #NEWLINE# #INDENT# Log . print_critical ( ( "Cluster name in config doesn't match the config file name: %s vs. %s" % ( self . name , cluster_name ) ) ) #NEWLINE# #UNINDENT# reg_expr = CLUSTER_NAME_REGEX . match ( self . name ) #NEWLINE# if ( not reg_expr ) : #NEWLINE# #INDENT# Log . print_critical ( ( 'Illegal cluster name: %s' % self . name ) ) #NEWLINE# #UNINDENT# self . zk_cluster = reg_expr . group ( 'zk' )