thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-21 23:21:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

More clear test

Browse Source
This commit is contained in:
alesapin 2020-06-02 21:47:30 +03:00
parent 6253e9b97b
commit d113a1cde7
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration/test_insert_distributed_load_balancing/test.py
View File

@ -19,7 +19,7 @@ def start_cluster():
finally: finally:
cluster.shutdown() cluster.shutdown()
def create_tables(**dist_settings): def create_tables():
n1.query('DROP TABLE IF EXISTS data') n1.query('DROP TABLE IF EXISTS data')
n2.query('DROP TABLE IF EXISTS data') n2.query('DROP TABLE IF EXISTS data')
n1.query('DROP TABLE IF EXISTS dist') n1.query('DROP TABLE IF EXISTS dist')
@ -34,10 +34,10 @@ def create_tables(**dist_settings):
data, data,
rand() rand()
) )
""", settings=dist_settings) """)
def insert_data(**settings): def insert_data(**settings):
create_tables(**settings) create_tables()
n1.query('INSERT INTO dist SELECT * FROM numbers(10)', settings=settings) n1.query('INSERT INTO dist SELECT * FROM numbers(10)', settings=settings)
n1.query('SYSTEM FLUSH DISTRIBUTED dist') n1.query('SYSTEM FLUSH DISTRIBUTED dist')