mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 16:50:48 +00:00
fix for style check.
This commit is contained in:
parent
76c75c947e
commit
0be7b09490
@ -495,23 +495,25 @@ void DDLWorker::parseQueryAndResolveHost(DDLTask & task)
|
|||||||
{
|
{
|
||||||
if (found_exact_match)
|
if (found_exact_match)
|
||||||
{
|
{
|
||||||
if(default_database == address.default_database)
|
if (default_database == address.default_database)
|
||||||
{
|
{
|
||||||
throw Exception(
|
throw Exception(
|
||||||
"There are two exactly the same ClickHouse instances " + address.readableString() + " in cluster "
|
"There are two exactly the same ClickHouse instances " + address.readableString() + " in cluster "
|
||||||
+ task.cluster_name, ErrorCodes::INCONSISTENT_CLUSTER_DEFINITION);
|
+ task.cluster_name,
|
||||||
}
|
ErrorCodes::INCONSISTENT_CLUSTER_DEFINITION);
|
||||||
else ///circular replication is used.
|
}
|
||||||
|
else ///circular replication is used.
|
||||||
{
|
{
|
||||||
is_circular_replicated = true;
|
is_circular_replicated = true;
|
||||||
auto query_with_table = dynamic_cast<ASTQueryWithTableAndOutput *>(task.query.get());
|
auto query_with_table = dynamic_cast<ASTQueryWithTableAndOutput *>(task.query.get());
|
||||||
if(query_with_table == nullptr || query_with_table->database.empty())
|
if (query_with_table == nullptr || query_with_table->database.empty())
|
||||||
{
|
{
|
||||||
throw Exception(
|
throw Exception(
|
||||||
"For a distributed DDL on circular replicated cluster its table name must be qualified by database name."
|
"For a distributed DDL on circular replicated cluster its table name must be qualified by database name.",
|
||||||
,ErrorCodes::INCONSISTENT_CLUSTER_DEFINITION);
|
ErrorCodes::INCONSISTENT_CLUSTER_DEFINITION);
|
||||||
}
|
}
|
||||||
if(default_database == query_with_table->database) return;
|
if (default_database == query_with_table->database)
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
found_exact_match = true;
|
found_exact_match = true;
|
||||||
|
Loading…
Reference in New Issue
Block a user