mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-18 04:12:19 +00:00
Drop helping tables when the whole table is done in clickhouse-copier
This commit is contained in:
parent
be27578294
commit
198a8d3b27
@ -316,9 +316,6 @@ void ClusterCopier::process(const ConnectionTimeouts & timeouts)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Delete helping tables in both cases (whole table is done or not)
|
|
||||||
dropHelpingTables(task_table);
|
|
||||||
|
|
||||||
if (!table_is_done)
|
if (!table_is_done)
|
||||||
{
|
{
|
||||||
throw Exception("Too many tries to process table " + task_table.table_id + ". Abort remaining execution",
|
throw Exception("Too many tries to process table " + task_table.table_id + ". Abort remaining execution",
|
||||||
@ -1044,6 +1041,11 @@ bool ClusterCopier::tryProcessTable(const ConnectionTimeouts & timeouts, TaskTab
|
|||||||
{
|
{
|
||||||
LOG_INFO(log, "Table {} is not processed yet.Copied {} of {}, will retry", task_table.table_id, finished_partitions, required_partitions);
|
LOG_INFO(log, "Table {} is not processed yet.Copied {} of {}, will retry", task_table.table_id, finished_partitions, required_partitions);
|
||||||
}
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
/// Delete helping tables in case that whole table is done
|
||||||
|
dropHelpingTables(task_table);
|
||||||
|
}
|
||||||
|
|
||||||
return table_is_done;
|
return table_is_done;
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user