diff --git a/src/Storages/ObjectStorage/StorageObjectStorageCluster.cpp b/src/Storages/ObjectStorage/StorageObjectStorageCluster.cpp index 2751e2dea569..8e3d3c794a71 100644 --- a/src/Storages/ObjectStorage/StorageObjectStorageCluster.cpp +++ b/src/Storages/ObjectStorage/StorageObjectStorageCluster.cpp @@ -872,4 +872,11 @@ void StorageObjectStorageCluster::onActionLockRemove(StorageActionBlockType acti IStorageCluster::onActionLockRemove(action_type); } +bool StorageObjectStorageCluster::prefersLargeBlocks() const +{ + if (pure_storage) + return pure_storage->prefersLargeBlocks(); + return IStorageCluster::prefersLargeBlocks(); +} + } diff --git a/src/Storages/ObjectStorage/StorageObjectStorageCluster.h b/src/Storages/ObjectStorage/StorageObjectStorageCluster.h index bcb97ae60ef1..5141db6638df 100644 --- a/src/Storages/ObjectStorage/StorageObjectStorageCluster.h +++ b/src/Storages/ObjectStorage/StorageObjectStorageCluster.h @@ -122,6 +122,8 @@ class StorageObjectStorageCluster : public IStorageCluster void onActionLockRemove(StorageActionBlockType action_type) override; + bool prefersLargeBlocks() const override; + private: void updateQueryToSendIfNeeded( ASTPtr & query,