Skip to content

Commit c082b3b

Browse files
committed
Fixed populating 'partition_key' and 'sorting_key' of system.tables
1 parent 69c3025 commit c082b3b

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

src/Storages/System/StorageSystemTables.cpp

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
#include <QueryPipeline/Pipe.h>
2323
#include <QueryPipeline/QueryPipelineBuilder.h>
2424
#include <Storages/MergeTree/MergeTreeData.h>
25-
#include <Storages/ObjectStorage/StorageObjectStorage.h>
25+
#include <Storages/ObjectStorage/StorageObjectStorageCluster.h>
2626
#include <Storages/ObjectStorage/DataLakes/IDataLakeMetadata.h>
2727
#include <Storages/SelectQueryInfo.h>
2828
#include <Storages/StorageView.h>
@@ -598,9 +598,8 @@ class TablesBlockSource : public ISource
598598
if (columns_mask[src_index++])
599599
{
600600
bool inserted = false;
601-
602601
// Extract from specific DataLake metadata if suitable
603-
if (auto * obj = typeid_cast<StorageObjectStorage *>(table.get()))
602+
if (auto * obj = dynamic_cast<StorageObjectStorageCluster *>(table.get()))
604603
{
605604
if (auto * dl_meta = obj->getExternalMetadata(context))
606605
{
@@ -627,7 +626,7 @@ class TablesBlockSource : public ISource
627626
bool inserted = false;
628627

629628
// Extract from specific DataLake metadata if suitable
630-
if (auto * obj = typeid_cast<StorageObjectStorage *>(table.get()))
629+
if (auto * obj = dynamic_cast<StorageObjectStorageCluster *>(table.get()))
631630
{
632631
if (auto * dl_meta = obj->getExternalMetadata(context))
633632
{
@@ -637,7 +636,6 @@ class TablesBlockSource : public ISource
637636
inserted = true;
638637
}
639638
}
640-
641639
}
642640

643641
if (!inserted)

0 commit comments

Comments
 (0)