diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py index 50e07fe5..609b6458 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -227,6 +227,7 @@ def handle_connection(connection, cert, request, local=False): f = open('/etc/confluent/cfg/myname', 'w') f.write(name) f.close() + cfm.clear_configuration() eventlet.spawn_n(connect_to_leader, rsp['collective']['fingerprint'], name) if 'enroll' == operation: #TODO(jjohnson2): error appropriately when asked to enroll, but the master is elsewhere diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index 3d148ecb..76f7b99c 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -497,8 +497,10 @@ def stop_leading(): def clear_configuration(): global _cfgstore + global _txcount _cfgstore = {} todelete = _config_areas + ('globals', 'collective', 'transactioncount') + _txcount = 0 for cfg in todelete: try: os.remove(os.path.join(ConfigManager._cfgdir, cfg))