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

fix build

Browse Source
This commit is contained in:
Nikita Mikhaylov 2020-02-25 15:38:11 +03:00
parent 5e01f348c5
commit 476d25b6b2
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
dbms/programs/copier/ClusterCopier.cpp
View File

@ -901,7 +901,7 @@ PartitionTaskStatus ClusterCopier::tryProcessPartitionTask(const ConnectionTimeo
tryLogCurrentException(log, "An error occurred while updating the config");
}
return PartitionTaskStatus::Finished;
return res;
}
PartitionTaskStatus ClusterCopier::iterateThroughAllPiecesInPartition(const ConnectionTimeouts & timeouts, ShardPartition & task_partition,
@ -909,12 +909,17 @@ PartitionTaskStatus ClusterCopier::iterateThroughAllPiecesInPartition(const Conn
{
const size_t total_number_of_pieces = task_partition.task_shard.task_table.number_of_splits;
/// ThreadPool maybe ??
PartitionTaskStatus res;
PartitionTaskStatus answer = PartitionTaskStatus::Finished;
for (size_t piece_number = 0; piece_number < total_number_of_pieces; piece_number++)
processPartitionPieceTaskImpl(timeouts, task_partition, piece_number, is_unprioritized_task);
return PartitionTaskStatus::Finished;
{
res = processPartitionPieceTaskImpl(timeouts, task_partition, piece_number, is_unprioritized_task);
if (res == PartitionTaskStatus::Error)
answer = res;
}
return answer;
}