diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index 9275693f..b5fa19bb 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -646,12 +646,13 @@ def commit_clear(): global _oldcfgstore _oldcfgstore = None _oldtxcount = 0 - todelete = _config_areas + ('globals', 'collective', 'transactioncount') - for cfg in todelete: - try: - os.remove(os.path.join(ConfigManager._cfgdir, cfg)) - except OSError as oe: - pass + with _synclock: + todelete = _config_areas + ('globals', 'collective', 'transactioncount') + for cfg in todelete: + try: + os.remove(os.path.join(ConfigManager._cfgdir, cfg)) + except OSError as oe: + pass ConfigManager.wait_for_sync(True) ConfigManager._bg_sync_to_file()