From 4cb7b7e49baadbaabb23f46fd0f45bce2d12b0a9 Mon Sep 17 00:00:00 2001
From: vdimir <vdimir@clickhouse.com>
Date: Wed, 6 Apr 2022 11:15:37 +0000
Subject: [PATCH] Create parent directories in DiskLocal::replaceFile

---
 src/Disks/DiskLocal.cpp                         |  1 +
 ...265_rename_join_ordinary_to_atomic.reference |  1 +
 .../02265_rename_join_ordinary_to_atomic.sql    | 17 +++++++++++++++++
 3 files changed, 19 insertions(+)
 create mode 100644 tests/queries/0_stateless/02265_rename_join_ordinary_to_atomic.reference
 create mode 100644 tests/queries/0_stateless/02265_rename_join_ordinary_to_atomic.sql

diff --git a/src/Disks/DiskLocal.cpp b/src/Disks/DiskLocal.cpp
index 44fdbb77323..a91db508295 100644
--- a/src/Disks/DiskLocal.cpp
+++ b/src/Disks/DiskLocal.cpp
@@ -333,6 +333,7 @@ void DiskLocal::replaceFile(const String & from_path, const String & to_path)
 {
     fs::path from_file = fs::path(disk_path) / from_path;
     fs::path to_file = fs::path(disk_path) / to_path;
+    fs::create_directories(to_file.parent_path());
     fs::rename(from_file, to_file);
 }
 
diff --git a/tests/queries/0_stateless/02265_rename_join_ordinary_to_atomic.reference b/tests/queries/0_stateless/02265_rename_join_ordinary_to_atomic.reference
new file mode 100644
index 00000000000..58c9bdf9d01
--- /dev/null
+++ b/tests/queries/0_stateless/02265_rename_join_ordinary_to_atomic.reference
@@ -0,0 +1 @@
+111
diff --git a/tests/queries/0_stateless/02265_rename_join_ordinary_to_atomic.sql b/tests/queries/0_stateless/02265_rename_join_ordinary_to_atomic.sql
new file mode 100644
index 00000000000..3ec995a6a24
--- /dev/null
+++ b/tests/queries/0_stateless/02265_rename_join_ordinary_to_atomic.sql
@@ -0,0 +1,17 @@
+-- Tags: no-parallel
+
+DROP DATABASE IF EXISTS 02265_atomic_db;
+DROP DATABASE IF EXISTS 02265_ordinary_db;
+
+CREATE DATABASE 02265_atomic_db ENGINE = Atomic;
+CREATE DATABASE 02265_ordinary_db ENGINE = Ordinary;
+
+CREATE TABLE 02265_ordinary_db.join_table ( `a` Int64 ) ENGINE = Join(`ALL`, LEFT, a);
+INSERT INTO 02265_ordinary_db.join_table VALUES (111);
+
+RENAME TABLE 02265_ordinary_db.join_table TO 02265_atomic_db.join_table;
+
+SELECT * FROM 02265_atomic_db.join_table;
+
+DROP DATABASE IF EXISTS 02265_atomic_db;
+DROP DATABASE IF EXISTS 02265_ordinary_db;