thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix 02010_lc_native flakiness (Query with id = 123456 is already running)

Browse Source
This commit is contained in:
Azat Khuzhin 2021-11-19 21:13:37 +03:00
parent c70cc62b5f
commit fbaa6804c2
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/queries/0_stateless/02010_lc_native.python
View File

@ -3,10 +3,12 @@
import socket
import os
import uuid
CLICKHOUSE_HOST = os.environ.get('CLICKHOUSE_HOST', '127.0.0.1')
CLICKHOUSE_PORT = int(os.environ.get('CLICKHOUSE_PORT_TCP', '900000'))
CLICKHOUSE_DATABASE = os.environ.get('CLICKHOUSE_DATABASE', 'default')
CLICKHOUSE_QUERY_ID = uuid.uuid4().hex
def writeVarUInt(x, ba):
for _ in range(0, 9):
@ -111,7 +113,7 @@ def receiveHello(s):
def serializeClientInfo(ba):
writeStringBinary('default', ba) # initial_user
writeStringBinary('123456', ba) # initial_query_id
writeStringBinary(CLICKHOUSE_QUERY_ID, ba) # initial_query_id
writeStringBinary('127.0.0.1:9000', ba) # initial_address
ba.extend([0] * 8) # initial_query_start_time_microseconds
ba.append(1) # TCP
@ -130,7 +132,7 @@ def serializeClientInfo(ba):
def sendQuery(s, query):
ba = bytearray()
writeVarUInt(1, ba) # query
writeStringBinary('123456', ba)
writeStringBinary(CLICKHOUSE_QUERY_ID, ba)
ba.append(1) # INITIAL_QUERY