diff --git a/dbms/src/Storages/StorageMergeTree.cpp b/dbms/src/Storages/StorageMergeTree.cpp
index 0c284c048be..3949faa0cb5 100644
--- a/dbms/src/Storages/StorageMergeTree.cpp
+++ b/dbms/src/Storages/StorageMergeTree.cpp
@@ -1228,7 +1228,7 @@ void StorageMergeTree::movePartitionToTable(const StoragePtr & dest_table, const
             for (MutableDataPartPtr & part : dst_parts)
                 dest_table_storage->renameTempPartAndReplace(part, &increment, &transaction, dest_data_parts_lock);
 
-            removePartsFromWorkingSet(src_parts, true, dest_data_parts_lock);
+            removePartsFromWorkingSet(src_parts, true, src_data_parts_lock);
             transaction.commit(&dest_data_parts_lock);
         }
 
diff --git a/dbms/src/Storages/StorageReplicatedMergeTree.cpp b/dbms/src/Storages/StorageReplicatedMergeTree.cpp
index a1230a21ee8..955544ca056 100644
--- a/dbms/src/Storages/StorageReplicatedMergeTree.cpp
+++ b/dbms/src/Storages/StorageReplicatedMergeTree.cpp
@@ -5115,7 +5115,7 @@ void StorageReplicatedMergeTree::movePartitionToTable(const StoragePtr & dest_ta
 
             op_results = zookeeper->multi(ops);
 
-            parts_to_remove = removePartsInRangeFromWorkingSet(drop_range, true, false, dest_data_parts_lock);
+            parts_to_remove = removePartsInRangeFromWorkingSet(drop_range, true, false, src_data_parts_lock);
             transaction.commit(&dest_data_parts_lock);
         }