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

fix flack test "02481_async_insert_dedup.python"

Browse Source
This commit is contained in:
Han Fei 2022-12-18 22:44:51 +01:00
parent 2fc2fecd5d
commit ee250174ab
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Storages/MergeTree/ReplicatedMergeTreeSink.cpp
View File

@ -485,7 +485,8 @@ void ReplicatedMergeTreeSinkImpl<true>::finishDelayedChunk(const ZooKeeperWithFa
auto conflict_block_ids = commitPart(zookeeper, partition.temp_part.part, partition.block_id, delayed_chunk->replicas_num, false);
if (conflict_block_ids.empty())
break;
LOG_DEBUG(log, "Found depulicate block IDs: {}, retry times {}", toString(conflict_block_ids), ++retry_times);
++retry_times;
LOG_DEBUG(log, "Found depulicate block IDs: {}, retry times {}", toString(conflict_block_ids), retry_times);
/// partition clean conflict
rewriteBlock(log, partition, conflict_block_ids);
if (partition.block_id.empty())

4
tests/queries/0_stateless/02481_async_insert_dedup.python
View File

@ -106,6 +106,10 @@ while (True):
errMsg = ""
for i in range(total_number):
expect = str(i+1)
if i >= len(result):
err = True
errMsg = "index {} is out of the size of result {}".format(i, len(result))
break
real = result[i]
if expect != real:
err = True