Update test.py

This commit is contained in:
Ivan Blinkov 2020-05-27 11:25:36 +03:00 committed by GitHub
parent 4a92ad11ec
commit d941c483b2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -97,6 +97,7 @@ def test_SYSTEM_FLUSH_LOGS(started_cluster):
instance = cluster.instances['ch1'] instance = cluster.instances['ch1']
instance.query(''' instance.query('''
SET log_queries = 0; SET log_queries = 0;
SYSTEM FLUSH LOGS;
TRUNCATE TABLE system.query_log; TRUNCATE TABLE system.query_log;
''') ''')
for i in range(4): for i in range(4):
@ -104,13 +105,13 @@ def test_SYSTEM_FLUSH_LOGS(started_cluster):
# by expiration of flush_interval_millisecond and test probable race condition. # by expiration of flush_interval_millisecond and test probable race condition.
time.sleep(0.5) time.sleep(0.5)
result = instance.query(''' result = instance.query('''
SET log_queries = 1;
SELECT 1 FORMAT Null; SELECT 1 FORMAT Null;
SET log_queries = 0; SET log_queries = 0;
SYSTEM FLUSH LOGS; SYSTEM FLUSH LOGS;
SELECT count() FROM system.query_log;''') SELECT count() FROM system.query_log;''')
instance.query(''' instance.query('''
SET log_queries = 0; SET log_queries = 0;
SYSTEM FLUSH LOGS;
TRUNCATE TABLE system.query_log; TRUNCATE TABLE system.query_log;
''') ''')
assert TSV(result) == TSV('4') assert TSV(result) == TSV('4')