Skip to content

Commit 17e867d

Browse files
committed
Fix distributedWriteIntoReplicatedMergeTreeFromClusterStorage
1 parent a10a84d commit 17e867d

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/Interpreters/InterpreterInsertQuery.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -772,6 +772,9 @@ InterpreterInsertQuery::distributedWriteIntoReplicatedMergeTreeFromClusterStorag
772772
if (!src_storage_cluster)
773773
return {};
774774

775+
if (src_storage_cluster->getOriginalClusterName().empty())
776+
return {};
777+
775778
if (!isInsertSelectTrivialEnoughForDistributedExecution(query))
776779
return {};
777780

0 commit comments

Comments
 (0)