diff --git a/tests/integration/test_disk_hdfs/__init__.py b/tests/integration/test_disk_hdfs/__init__.py
new file mode 100644
index 00000000000..e69de29bb2d
diff --git a/tests/integration/test_disk_hdfs/configs/log_conf.xml b/tests/integration/test_disk_hdfs/configs/log_conf.xml
new file mode 100644
index 00000000000..f9d15e572aa
--- /dev/null
+++ b/tests/integration/test_disk_hdfs/configs/log_conf.xml
@@ -0,0 +1,11 @@
+
+
+ trace
+ /var/log/clickhouse-server/log.log
+ /var/log/clickhouse-server/log.err.log
+ 1000M
+ 10
+ /var/log/clickhouse-server/stderr.log
+ /var/log/clickhouse-server/stdout.log
+
+
diff --git a/tests/integration/test_disk_hdfs/configs/storage.xml b/tests/integration/test_disk_hdfs/configs/storage.xml
new file mode 100644
index 00000000000..92afa92cb14
--- /dev/null
+++ b/tests/integration/test_disk_hdfs/configs/storage.xml
@@ -0,0 +1,21 @@
+
+
+
+
+
+ hdfs
+ hdfs://hdfs1:9000/
+
+
+
+
+
+
+
+ hdfs
+
+
+
+
+
+
diff --git a/tests/integration/test_disk_hdfs/test.py b/tests/integration/test_disk_hdfs/test.py
new file mode 100644
index 00000000000..1336bc539d4
--- /dev/null
+++ b/tests/integration/test_disk_hdfs/test.py
@@ -0,0 +1,27 @@
+import os
+import pytest
+from helpers.cluster import ClickHouseCluster
+from helpers.hdfs_api import HDFSApi
+
+cluster = ClickHouseCluster(__file__)
+node1 = cluster.add_instance('node1', main_configs=[
+ 'configs/storage.xml',
+ 'configs/log_conf.xml'], with_hdfs=True)
+
+@pytest.fixture(scope="module")
+def started_cluster():
+ try:
+ cluster.start()
+ yield cluster
+
+ finally:
+ cluster.shutdown()
+
+
+def test_read_write(started_cluster):
+ node1.query("DROP TABLE IF EXISTS simple_test")
+ node1.query("CREATE TABLE simple_test (id UInt64) Engine=TinyLog SETTINGS disk = 'hdfs'")
+ node1.query("INSERT INTO simple_test SELECT number FROM numbers(3)")
+ node1.query("INSERT INTO simple_test SELECT number FROM numbers(3, 3)")
+ assert node1.query("SELECT * FROM simple_test") == "0\n1\n2\n3\n4\n5\n"
+