aa

Author: arthurpassos

src/Databases/DatabaseReplicated.cpp

@@ -2110,7 +2110,8 @@ bool DatabaseReplicated::shouldReplicateQuery(const ContextPtr & query_context,
     if (const auto * alter = query_ptr->as<const ASTAlterQuery>())
     {
         if (alter->isAttachAlter() || alter->isFetchAlter() || alter->isDropPartitionAlter()
-            || is_keeper_map_table(query_ptr) || alter->isFreezeAlter() || alter->isUnlockSnapshot())
+            || is_keeper_map_table(query_ptr) || alter->isFreezeAlter() || alter->isUnlockSnapshot()
+            || alter->isExportPartAlter())
             return false;
 
         if (has_many_shards() || !is_replicated_table(query_ptr))

src/Interpreters/DDLWorker.cpp

@@ -747,7 +747,8 @@ bool DDLWorker::taskShouldBeExecutedOnLeader(const ASTPtr & ast_ddl, const Stora
             alter->isFreezeAlter() ||
             alter->isUnlockSnapshot() ||
             alter->isMovePartitionToDiskOrVolumeAlter() ||
-            alter->isCommentAlter())
+            alter->isCommentAlter() ||
+            alter->isExportPartAlter())
             return false;
     }
 

src/Interpreters/executeDDLQueryOnCluster.cpp

@@ -53,6 +53,8 @@ bool isSupportedAlterTypeForOnClusterDDLQuery(int type)
         ASTAlterCommand::ATTACH_PARTITION,
         /// Usually followed by ATTACH PARTITION
         ASTAlterCommand::FETCH_PARTITION,
+        /// Data operation that should be executed locally on each replica
+        ASTAlterCommand::EXPORT_PART,
         /// Logical error
         ASTAlterCommand::NO_TYPE,
     };

src/Parsers/ASTAlterQuery.cpp

@@ -647,6 +647,11 @@ bool ASTAlterQuery::isMovePartitionToDiskOrVolumeAlter() const
     return false;
 }
 
+bool ASTAlterQuery::isExportPartAlter() const
+{
+    return isOneCommandTypeOnly(ASTAlterCommand::EXPORT_PART);
+}
+
 
 /** Get the text that identifies this element. */
 String ASTAlterQuery::getID(char delim) const

src/Parsers/ASTAlterQuery.h

@@ -264,6 +264,8 @@ class ASTAlterQuery : public ASTQueryWithTableAndOutput, public ASTQueryWithOnCl
 
     bool isMovePartitionToDiskOrVolumeAlter() const;
 
+    bool isExportPartAlter() const;
+
     bool isCommentAlter() const;
 
     String getID(char) const override;

tests/queries/0_stateless/03572_export_replicated_merge_tree_part_to_object_storage.sh

@@ -1,5 +1,5 @@
 #!/usr/bin/env bash
-# Tags: replica, no-parallel
+# Tags: replica, no-parallel, no-replicated-database
 
 CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
 # shellcheck source=../shell_config.sh