#NEWLINE# def test_install_when_topology_has_ips( self ) : #NEWLINE# #INDENT# installer = StandalonePrestoInstaller ( self ) #NEWLINE# ips = self . cluster . get_ip_address_dict ( ) #NEWLINE# topology = { #NEWLINE# #INDENT# 'coordinator' : ips [ self . cluster . master ] , #NEWLINE# 'workers' : [ ips [ self . cluster . slaves [ 0 ] ] ] , #NEWLINE# #UNINDENT# } #NEWLINE# self . upload_topology ( topology ) #NEWLINE# self . cluster . write_content_to_host ( 'connector.name=jmx' , os . path . join ( constants . CONNECTORS_DIR , 'jmx.properties' ) , self . cluster . master ) #NEWLINE# cmd_output = installer . install ( ) . splitlines ( ) #NEWLINE# expected = [ ( 'Deploying rpm on %s...' % ips [ self . cluster . master ] ) , ( 'Deploying rpm on %s...' % ips [ self . cluster . slaves [ 0 ] ] ) , ( 'Package deployed successfully on: ' + ips [ self . cluster . master ] ) , ( 'Package installed successfully on: ' + ips [ self . cluster . master ] ) , ( 'Package deployed successfully on: ' + ips [ self . cluster . slaves [ 0 ] ] ) , ( 'Package installed successfully on: ' + ips [ self . cluster . slaves [ 0 ] ] ) , ( 'Deploying configuration on: ' + ips [ self . cluster . master ] ) , ( 'Deploying jmx.properties, tpch.properties connector configurations on: ' + ips [ self . cluster . master ] ) , ( 'Deploying configuration on: ' + ips [ self . cluster . slaves [ 0 ] ] ) , ( 'Deploying jmx.properties, tpch.properties connector configurations on: ' + ips [ self . cluster . slaves [ 0 ] ] ) ] #NEWLINE# cmd_output . sort ( ) #NEWLINE# expected . sort ( ) #NEWLINE# self . assertRegexpMatchesLineByLine ( expected , cmd_output ) #NEWLINE# self . assert_installed_with_regex_configs ( self . cluster . master , [ self . cluster . slaves [ 0 ] ] ) #NEWLINE# for container in [ self . cluster . master , self . cluster . slaves [ 0 ] ] : #NEWLINE# #INDENT# self . assert_has_jmx_connector ( container )