thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 15:42:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

modify test for Integration Tests Flaky Check

Browse Source
This commit is contained in:
taichong 2020-11-03 13:22:39 +08:00
parent e5da2d4086
commit 6c8b5b573b
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/integration/test_materialize_mysql_database/materialize_with_ddl.py
View File

@ -5,7 +5,7 @@ import pymysql.cursors
import pytest import pytest
from helpers.client import QueryRuntimeException from helpers.client import QueryRuntimeException
def check_query(clickhouse_node, query, result_set, retry_count=3, interval_seconds=3): def check_query(clickhouse_node, query, result_set, retry_count=5, interval_seconds=30):
lastest_result = '' lastest_result = ''
for index in range(retry_count): for index in range(retry_count):
lastest_result = clickhouse_node.query(query) lastest_result = clickhouse_node.query(query)
@ -477,7 +477,6 @@ def err_sync_user_privs_with_materialize_mysql_database(clickhouse_node, mysql_n
# wait MaterializeMySQL read binlog events # wait MaterializeMySQL read binlog events
check_query(clickhouse_node, "SELECT count() FROM test_database.test_table_1 FORMAT TSV", "6\n", 30, 5) check_query(clickhouse_node, "SELECT count() FROM test_database.test_table_1 FORMAT TSV", "6\n", 30, 5)
print mysql result for test
mysql_node.query("INSERT INTO test_database.test_table_1 VALUES(7);") mysql_node.query("INSERT INTO test_database.test_table_1 VALUES(7);")
check_query(clickhouse_node, "SELECT count() FROM test_database.test_table_1 FORMAT TSV", "7\n") check_query(clickhouse_node, "SELECT count() FROM test_database.test_table_1 FORMAT TSV", "7\n")
clickhouse_node.query("DROP DATABASE test_database;") clickhouse_node.query("DROP DATABASE test_database;")