diff --git a/tests/integration/test_log_family_hdfs/test.py b/tests/integration/test_log_family_hdfs/test.py
index fcf64381dd9..3d067f0febe 100644
--- a/tests/integration/test_log_family_hdfs/test.py
+++ b/tests/integration/test_log_family_hdfs/test.py
@@ -27,7 +27,7 @@ def started_cluster():
 
 
 def assert_objects_count(started_cluster, objects_count, path='data/'):
-    fs = HdfsClient(hosts=cluster.hdfs_ip)
+    fs = HdfsClient(hosts=started_cluster.hdfs_ip)
     hdfs_objects = fs.listdir('/clickhouse')
     assert objects_count == len(hdfs_objects)