From 22dd47c13fc97b8adf726fc42ca94847f1c76dd6 Mon Sep 17 00:00:00 2001
From: Alexey Milovidov <milovidov@yandex-team.ru>
Date: Fri, 12 Jun 2020 23:24:17 +0300
Subject: [PATCH] Added a test

---
 .../01307_multiple_leaders.reference          |  2 +
 .../0_stateless/01307_multiple_leaders.sh     | 39 +++++++++++++++++++
 2 files changed, 41 insertions(+)
 create mode 100644 tests/queries/0_stateless/01307_multiple_leaders.reference
 create mode 100755 tests/queries/0_stateless/01307_multiple_leaders.sh

diff --git a/tests/queries/0_stateless/01307_multiple_leaders.reference b/tests/queries/0_stateless/01307_multiple_leaders.reference
new file mode 100644
index 00000000000..576441b288d
--- /dev/null
+++ b/tests/queries/0_stateless/01307_multiple_leaders.reference
@@ -0,0 +1,2 @@
+2000	1999000
+2000	1999000
diff --git a/tests/queries/0_stateless/01307_multiple_leaders.sh b/tests/queries/0_stateless/01307_multiple_leaders.sh
new file mode 100755
index 00000000000..0bf5e0b13bf
--- /dev/null
+++ b/tests/queries/0_stateless/01307_multiple_leaders.sh
@@ -0,0 +1,39 @@
+#!/usr/bin/env bash
+
+CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
+. $CURDIR/../shell_config.sh
+
+set -e
+
+$CLICKHOUSE_CLIENT -n --query "
+DROP TABLE IF EXISTS r0;
+DROP TABLE IF EXISTS r1;
+
+CREATE TABLE r0 (x UInt64) ENGINE = ReplicatedMergeTree('/test/table', 'r0') ORDER BY x SETTINGS min_bytes_for_wide_part = '10M';
+CREATE TABLE r1 (x UInt64) ENGINE = ReplicatedMergeTree('/test/table', 'r1') ORDER BY x SETTINGS min_bytes_for_wide_part = '10M';
+"
+
+function thread()
+{
+    REPLICA=$1
+    ITERATIONS=$2
+
+    $CLICKHOUSE_CLIENT --max_block_size 1 --min_insert_block_size_rows 0 --min_insert_block_size_bytes 0 --query "INSERT INTO r$REPLICA SELECT number * 2 + $REPLICA FROM numbers($ITERATIONS)"
+}
+
+
+thread 0 1000 &
+thread 1 1000 &
+
+wait
+
+$CLICKHOUSE_CLIENT -n --query "
+SYSTEM SYNC REPLICA r0;
+SYSTEM SYNC REPLICA r1;
+
+SELECT count(), sum(x) FROM r0;
+SELECT count(), sum(x) FROM r1;
+
+DROP TABLE r0;
+DROP TABLE r1;
+"