@@ -6243,9 +6243,8 @@ class ControlScript(object):
6243
6243
6244
6244
# Get the current master leader known to a tserver using api/v1/masters endpoint
6245
6245
# of the tserver.
6246
- def get_current_master_leader_from_api (self , tserverIP , timeout = 60 ):
6247
- tserver_addr = "{}:{}" .format (tserverIP ,
6248
- self .configs .saved_data .get ("tserver_webserver_port" ))
6246
+ def get_current_master_leader_from_api (self , tserverIP , tserver_webserver_port , timeout = 60 ):
6247
+ tserver_addr = "{}:{}" .format (tserverIP , tserver_webserver_port )
6249
6248
try :
6250
6249
tserverMastersAPI = "http://{}/api/v1/masters" .format (tserver_addr )
6251
6250
Output .log ("Trying to get masters information from {}" .format (tserverMastersAPI ) +
@@ -6961,6 +6960,13 @@ class ControlScript(object):
6961
6960
self .setup_env_init .set_ycql_keyspace (args .keyspace )
6962
6961
6963
6962
if args .parser == "start" :
6963
+ master_webserver_port = self .configs .saved_data .get ("master_webserver_port" )
6964
+ if args .master_webserver_port is not None :
6965
+ master_webserver_port = args .master_webserver_port
6966
+
6967
+ tserver_webserver_port = self .configs .saved_data .get ("tserver_webserver_port" )
6968
+ if args .tserver_webserver_port is not None :
6969
+ tserver_webserver_port = args .tserver_webserver_port
6964
6970
if args .read_replica and not args .join :
6965
6971
Output .print_out (Output .make_red ("ERROR" ) + ": read_replica neds to be " +
6966
6972
"started with --join flag." )
@@ -7044,12 +7050,12 @@ class ControlScript(object):
7044
7050
if not cluster_member :
7045
7051
# Check if tserver webserver at join_IP is reachable or not
7046
7052
# Also get the leader master(used to get the info of all tservers)
7047
- master_leader = self .get_current_master_leader_from_api (args .join )
7053
+ master_leader = self .get_current_master_leader_from_api (args .join ,
7054
+ tserver_webserver_port )
7048
7055
args .join = master_leader
7049
7056
7050
7057
# Get info on all tservers
7051
- master_leader_hostport = "{}:{}" .format (master_leader ,
7052
- self .configs .saved_data .get ("master_webserver_port" ))
7058
+ master_leader_hostport = "{}:{}" .format (master_leader , master_webserver_port )
7053
7059
tservers_info = dict (self .get_all_tserver_info (master_leader_hostport ))
7054
7060
7055
7061
# Check if any existing node has the same IP as advertise address
@@ -7125,8 +7131,7 @@ class ControlScript(object):
7125
7131
7126
7132
if args .insecure :
7127
7133
if args .join and not cluster_member :
7128
- master_hostport = "{}:{}" .format (args .join ,
7129
- self .configs .saved_data .get ("master_webserver_port" ))
7134
+ master_hostport = "{}:{}" .format (args .join , master_webserver_port )
7130
7135
if self .is_leader_master_secure (master_hostport ):
7131
7136
# Case Scenario: When a User starts the 1st node in secure mode and tries
7132
7137
# to start the second node in insecure mode
@@ -7136,8 +7141,7 @@ class ControlScript(object):
7136
7141
"secure and an insecure node." )
7137
7142
elif args .secure :
7138
7143
if args .join and not cluster_member :
7139
- master_hostport = "{}:{}" .format (args .join ,
7140
- self .configs .saved_data .get ("master_webserver_port" ))
7144
+ master_hostport = "{}:{}" .format (args .join , master_webserver_port )
7141
7145
if not self .is_leader_master_secure (master_hostport ):
7142
7146
# Case Scenario: When the user starts the 1st node in insecure mode and
7143
7147
# tries to start the second node in secure mode.
0 commit comments