Skip to content

Commit 582b042

Browse files
committed
Cleanup setting for secondary queries
1 parent 024a0b4 commit 582b042

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

src/Storages/ObjectStorage/StorageObjectStorageCluster.cpp

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -268,6 +268,20 @@ void StorageObjectStorageCluster::updateQueryToSendIfNeeded(
268268
if (cluster_name_in_settings)
269269
{
270270
configuration->addStructureAndFormatToArgsIfNeeded(args, structure, configuration->format, context, /*with_structure=*/true);
271+
272+
auto * select_query = query->as<ASTSelectQuery>();
273+
if (select_query)
274+
{
275+
auto settings = select_query->settings();
276+
if (settings)
277+
{
278+
auto & settings_ast = settings->as<ASTSetQuery &>();
279+
if (settings_ast.changes.removeSetting("object_storage_cluster") && settings_ast.changes.empty())
280+
{
281+
select_query->setExpression(ASTSelectQuery::Expression::SETTINGS, {});
282+
}
283+
}
284+
}
271285
}
272286
else
273287
{

0 commit comments

Comments
 (0)