| 994 | } |
| 995 | |
| 996 | bool 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 | |
| 1010 | bool RemoteQueryExecutor::processParallelReplicaPacketIfAny() |
| 1011 | { |
no test coverage detected