add a silly test

Author: arthurpassos

src/Storages/StorageReplicatedMergeTree.cpp

@@ -4458,6 +4458,7 @@ void StorageReplicatedMergeTree::exportMergeTreePartitionUpdatingTask()
     }
 
     export_merge_tree_partition_updating_task->scheduleAfter(30 * 1000);
+    export_merge_tree_partition_select_task->schedule();
 }
 
 void StorageReplicatedMergeTree::selectPartsToExport()
@@ -4838,9 +4839,6 @@ void StorageReplicatedMergeTree::selectPartsToExport()
 
                     }
                 });
-
-                /// managed to schedule a task, re-run immediately to pick up more tasks if possible
-                export_merge_tree_partition_select_task->schedule();
             }
             catch (...)
             {

tests/queries/0_stateless/03604_export_merge_tree_partition.reference

@@ -0,0 +1,31 @@
+
+Select from source table
+1	2020
+2	2020
+3	2020
+4	2021
+5	2021
+6	2022
+7	2022
+Select from destination table
+1	2020
+2	2020
+3	2020
+4	2021
+Export partition 2022
+Select from destination table again
+1	2020
+2	2020
+3	2020
+4	2021
+5	2021
+6	2022
+7	2022
+---- Data in roundtrip ReplicatedMergeTree table (should match s3_table)
+1	2020
+2	2020
+3	2020
+4	2021
+5	2021
+6	2022
+7	2022

tests/queries/0_stateless/03604_export_merge_tree_partition.sh

@@ -0,0 +1,54 @@
+#!/usr/bin/env bash
+# Tags: replica, no-parallel, no-replicated-database
+
+CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
+# shellcheck source=../shell_config.sh
+. "$CURDIR"/../shell_config.sh
+
+rmt_table="rmt_table_${RANDOM}"
+s3_table="s3_table_${RANDOM}"
+rmt_table_roundtrip="rmt_table_roundtrip_${RANDOM}"
+
+query() {
+    $CLICKHOUSE_CLIENT --query "$1"
+}
+
+query "DROP TABLE IF EXISTS $rmt_table, $s3_table, $rmt_table_roundtrip"
+
+query "CREATE TABLE $rmt_table (id UInt64, year UInt16) ENGINE = ReplicatedMergeTree('/clickhouse/tables/{database}/$rmt_table', 'replica1') PARTITION BY year ORDER BY tuple()"
+query "CREATE TABLE $s3_table (id UInt64, year UInt16) ENGINE = S3(s3_conn, filename='$s3_table', format=Parquet, partition_strategy='hive') PARTITION BY year"
+
+query "INSERT INTO $rmt_table VALUES (1, 2020), (2, 2020), (4, 2021)"
+
+query "INSERT INTO $rmt_table VALUES (3, 2020), (5, 2021)"
+
+query "INSERT INTO $rmt_table VALUES (6, 2022), (7, 2022)"
+
+query "ALTER TABLE $rmt_table EXPORT PARTITION ID '2020' TO TABLE $s3_table SETTINGS allow_experimental_export_merge_tree_part = 1"
+
+query "ALTER TABLE $rmt_table EXPORT PARTITION ID '2021' TO TABLE $s3_table SETTINGS allow_experimental_export_merge_tree_part = 1"
+
+# todo poll some kind of status
+sleep 15
+
+echo "Select from source table"
+query "SELECT * FROM $rmt_table ORDER BY id"
+
+echo "Select from destination table"
+query "SELECT * FROM $s3_table ORDER BY id"
+
+echo "Export partition 2022"
+query "ALTER TABLE $rmt_table EXPORT PARTITION ID '2022' TO TABLE $s3_table SETTINGS allow_experimental_export_merge_tree_part = 1"
+
+# todo poll some kind of status
+sleep 5
+
+echo "Select from destination table again"
+query "SELECT * FROM $s3_table ORDER BY id"
+
+query "CREATE TABLE $rmt_table_roundtrip ENGINE = ReplicatedMergeTree('/clickhouse/tables/{database}/$rmt_table_roundtrip', 'replica1') PARTITION BY year ORDER BY tuple() AS SELECT * FROM $s3_table"
+
+echo "---- Data in roundtrip ReplicatedMergeTree table (should match s3_table)"
+query "SELECT * FROM $rmt_table_roundtrip ORDER BY id"
+
+query "DROP TABLE IF EXISTS $rmt_table, $s3_table, $rmt_table_roundtrip"