diff --git a/tests/integration/test_disk_types/configs/storage.xml b/tests/integration/test_disk_types/configs/storage.xml
index e933c7781ea..78e7fb01553 100644
--- a/tests/integration/test_disk_types/configs/storage.xml
+++ b/tests/integration/test_disk_types/configs/storage.xml
@@ -13,7 +13,7 @@
             </disk_memory>
             <disk_hdfs>
                 <type>hdfs</type>
-                <endpoint>http://hdfs1:9000/data/</endpoint>
+                <endpoint>hdfs://hdfs1:9000/data/</endpoint>
             </disk_hdfs>
             <disk_encrypted>
                 <type>encrypted</type>
diff --git a/tests/integration/test_storage_hdfs/test.py b/tests/integration/test_storage_hdfs/test.py
index 995f704262e..64f94a52a70 100644
--- a/tests/integration/test_storage_hdfs/test.py
+++ b/tests/integration/test_storage_hdfs/test.py
@@ -100,7 +100,7 @@ def test_bad_hdfs_uri(started_cluster):
             "create table BadStorage1 (id UInt32, name String, weight Float64) ENGINE = HDFS('hads:hgsdfs100500:9000/other_storage', 'TSV')")
     except Exception as ex:
         print(ex)
-        assert "Illegal HDFS URI" in str(ex)
+        assert "Bad hdfs url" in str(ex)
     try:
         node1.query(
             "create table BadStorage2 (id UInt32, name String, weight Float64) ENGINE = HDFS('hdfs://hdfs100500:9000/other_storage', 'TSV')")