MCPcopy Create free account
hub / github.com/ClickHouse/ClickHouse / needToSkipUnavailableShard

Method needToSkipUnavailableShard

src/QueryPipeline/RemoteQueryExecutor.cpp:996–1008  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

994}
995
996bool RemoteQueryExecutor::needToSkipUnavailableShard()
997{
998 if (context->getSettingsRef()[Setting::skip_unavailable_shards] && (0 == connections->size()))
999 {
1000 if (!shard_skip_reported && unavailable_shard_tracker)
1001 {
1002 shard_skip_reported = true;
1003 unavailable_shard_tracker->onShardSkipped();
1004 }
1005 return true;
1006 }
1007 return false;
1008}
1009
1010bool RemoteQueryExecutor::processParallelReplicaPacketIfAny()
1011{

Callers 1

runMethod · 0.80

Calls 2

onShardSkippedMethod · 0.80
sizeMethod · 0.45

Tested by

no test coverage detected