diff --git a/src/Storages/Hive/StorageHiveCluster.cpp b/src/Storages/Hive/StorageHiveCluster.cpp
index 9282dafc4411..78593069ec00 100644
--- a/src/Storages/Hive/StorageHiveCluster.cpp
+++ b/src/Storages/Hive/StorageHiveCluster.cpp
@@ -101,7 +101,7 @@ Pipe StorageHiveCluster::read(
                 auto connection = std::make_shared<Connection>(
                     node.host_name,
                     node.port,
-                    context_->getGlobalContext()->getCurrentDatabase(),
+                    context_->getCurrentDatabase(),
                     node.user,
                     node.password,
                     node.cluster,