Fix style once more

This commit is contained in:
Igor Nikonov 2023-08-14 23:27:36 +00:00
parent e82b6b02ca
commit 9f7a25eead

View File

@ -240,8 +240,8 @@ void ReadFromRemote::addPipe(Pipes & pipes, const ClusterProxy::SelectStreamFact
if (context->getParallelReplicasMode() == Context::ParallelReplicasMode::READ_TASKS)
{
LOG_DEBUG(&Poco::Logger::get(__FUNCTION__), "_cluster_for_parallel_replicas: {}", cluster_name);
scalars["_cluster_for_parallel_replicas"] = Block{
{DataTypeString().createColumnConst(1, cluster_name), std::make_shared<DataTypeString>(), "_cluster_for_parallel_replicas"}};
scalars["_cluster_for_parallel_replicas"] =
Block{{DataTypeString().createColumnConst(1, cluster_name), std::make_shared<DataTypeString>(), "_cluster_for_parallel_replicas"}};
}
std::shared_ptr<RemoteQueryExecutor> remote_query_executor;