mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 08:40:50 +00:00
fix flaky window view tests
This commit is contained in:
parent
dc21d423d1
commit
9aa98d7b99
@ -1,2 +1 @@
|
|||||||
0
|
|
||||||
1
|
1
|
||||||
|
27
tests/queries/0_stateless/01053_window_view_proc_hop_to_now.sh
Executable file
27
tests/queries/0_stateless/01053_window_view_proc_hop_to_now.sh
Executable file
@ -0,0 +1,27 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
|
||||||
|
CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
|
||||||
|
# shellcheck source=../shell_config.sh
|
||||||
|
. "$CURDIR"/../shell_config.sh
|
||||||
|
|
||||||
|
$CLICKHOUSE_CLIENT --multiquery <<EOF
|
||||||
|
SET allow_experimental_window_view = 1;
|
||||||
|
DROP TABLE IF EXISTS mt;
|
||||||
|
DROP TABLE IF EXISTS dst;
|
||||||
|
DROP TABLE IF EXISTS wv;
|
||||||
|
|
||||||
|
CREATE TABLE dst(count UInt64) Engine=MergeTree ORDER BY tuple();
|
||||||
|
CREATE TABLE mt(a Int32) ENGINE=MergeTree ORDER BY tuple();
|
||||||
|
CREATE WINDOW VIEW wv TO dst AS SELECT count(a) AS count FROM mt GROUP BY hop(now('US/Samoa'), INTERVAL '1' SECOND, INTERVAL '1' SECOND, 'US/Samoa') AS wid;
|
||||||
|
|
||||||
|
INSERT INTO mt VALUES (1);
|
||||||
|
EOF
|
||||||
|
|
||||||
|
while true; do
|
||||||
|
$CLICKHOUSE_CLIENT --query="SELECT count FROM dst" | grep -q "1" && break || sleep 1 ||:
|
||||||
|
done
|
||||||
|
|
||||||
|
$CLICKHOUSE_CLIENT --query="SELECT count FROM dst"
|
||||||
|
$CLICKHOUSE_CLIENT --query="DROP TABLE wv"
|
||||||
|
$CLICKHOUSE_CLIENT --query="DROP TABLE mt"
|
||||||
|
$CLICKHOUSE_CLIENT --query="DROP TABLE dst"
|
@ -1,17 +0,0 @@
|
|||||||
SET allow_experimental_window_view = 1;
|
|
||||||
|
|
||||||
DROP TABLE IF EXISTS mt;
|
|
||||||
DROP TABLE IF EXISTS dst;
|
|
||||||
DROP TABLE IF EXISTS wv;
|
|
||||||
|
|
||||||
CREATE TABLE dst(count UInt64) Engine=MergeTree ORDER BY tuple();
|
|
||||||
CREATE TABLE mt(a Int32) ENGINE=MergeTree ORDER BY tuple();
|
|
||||||
CREATE WINDOW VIEW wv TO dst AS SELECT count(a) AS count FROM mt GROUP BY hop(now('US/Samoa'), INTERVAL '1' SECOND, INTERVAL '1' SECOND, 'US/Samoa') AS wid;
|
|
||||||
|
|
||||||
INSERT INTO mt VALUES (1);
|
|
||||||
SELECT sleep(3);
|
|
||||||
SELECT count from dst;
|
|
||||||
|
|
||||||
DROP TABLE wv;
|
|
||||||
DROP TABLE mt;
|
|
||||||
DROP TABLE dst;
|
|
@ -1,2 +1 @@
|
|||||||
0
|
|
||||||
1
|
1
|
||||||
|
27
tests/queries/0_stateless/01054_window_view_proc_tumble_to.sh
Executable file
27
tests/queries/0_stateless/01054_window_view_proc_tumble_to.sh
Executable file
@ -0,0 +1,27 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
|
||||||
|
CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
|
||||||
|
# shellcheck source=../shell_config.sh
|
||||||
|
. "$CURDIR"/../shell_config.sh
|
||||||
|
|
||||||
|
$CLICKHOUSE_CLIENT --multiquery <<EOF
|
||||||
|
SET allow_experimental_window_view = 1;
|
||||||
|
DROP TABLE IF EXISTS mt;
|
||||||
|
DROP TABLE IF EXISTS dst;
|
||||||
|
DROP TABLE IF EXISTS wv;
|
||||||
|
|
||||||
|
CREATE TABLE dst(count UInt64) Engine=MergeTree ORDER BY tuple();
|
||||||
|
CREATE TABLE mt(a Int32, timestamp DateTime) ENGINE=MergeTree ORDER BY tuple();
|
||||||
|
CREATE WINDOW VIEW wv TO dst AS SELECT count(a) AS count FROM mt GROUP BY tumble(timestamp, INTERVAL '1' SECOND, 'US/Samoa') AS wid;
|
||||||
|
|
||||||
|
INSERT INTO mt VALUES (1, now('US/Samoa') + 1);
|
||||||
|
EOF
|
||||||
|
|
||||||
|
while true; do
|
||||||
|
$CLICKHOUSE_CLIENT --query="SELECT count FROM dst" | grep -q "1" && break || sleep 1 ||:
|
||||||
|
done
|
||||||
|
|
||||||
|
$CLICKHOUSE_CLIENT --query="SELECT count FROM dst"
|
||||||
|
$CLICKHOUSE_CLIENT --query="DROP TABLE wv"
|
||||||
|
$CLICKHOUSE_CLIENT --query="DROP TABLE mt"
|
||||||
|
$CLICKHOUSE_CLIENT --query="DROP TABLE dst"
|
@ -1,18 +0,0 @@
|
|||||||
SET allow_experimental_window_view = 1;
|
|
||||||
|
|
||||||
DROP TABLE IF EXISTS mt;
|
|
||||||
DROP TABLE IF EXISTS dst;
|
|
||||||
DROP TABLE IF EXISTS wv;
|
|
||||||
DROP TABLE IF EXISTS `.inner.wv`;
|
|
||||||
|
|
||||||
CREATE TABLE dst(count UInt64) Engine=MergeTree ORDER BY tuple();
|
|
||||||
CREATE TABLE mt(a Int32, timestamp DateTime) ENGINE=MergeTree ORDER BY tuple();
|
|
||||||
CREATE WINDOW VIEW wv TO dst AS SELECT count(a) AS count FROM mt GROUP BY tumble(timestamp, INTERVAL '1' SECOND, 'US/Samoa') AS wid;
|
|
||||||
|
|
||||||
INSERT INTO mt VALUES (1, now('US/Samoa') + 1);
|
|
||||||
SELECT sleep(3);
|
|
||||||
SELECT count from dst;
|
|
||||||
|
|
||||||
DROP TABLE wv;
|
|
||||||
DROP TABLE mt;
|
|
||||||
DROP TABLE dst;
|
|
@ -1,2 +1 @@
|
|||||||
0
|
|
||||||
1
|
1
|
||||||
|
27
tests/queries/0_stateless/01055_window_view_proc_hop_to.sh
Executable file
27
tests/queries/0_stateless/01055_window_view_proc_hop_to.sh
Executable file
@ -0,0 +1,27 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
|
||||||
|
CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
|
||||||
|
# shellcheck source=../shell_config.sh
|
||||||
|
. "$CURDIR"/../shell_config.sh
|
||||||
|
|
||||||
|
$CLICKHOUSE_CLIENT --multiquery <<EOF
|
||||||
|
SET allow_experimental_window_view = 1;
|
||||||
|
DROP TABLE IF EXISTS mt;
|
||||||
|
DROP TABLE IF EXISTS dst;
|
||||||
|
DROP TABLE IF EXISTS wv;
|
||||||
|
|
||||||
|
CREATE TABLE dst(count UInt64) Engine=MergeTree ORDER BY tuple();
|
||||||
|
CREATE TABLE mt(a Int32, timestamp DateTime) ENGINE=MergeTree ORDER BY tuple();
|
||||||
|
CREATE WINDOW VIEW wv TO dst AS SELECT count(a) AS count FROM mt GROUP BY hop(timestamp, INTERVAL '1' SECOND, INTERVAL '1' SECOND, 'US/Samoa') AS wid;
|
||||||
|
|
||||||
|
INSERT INTO mt VALUES (1, now('US/Samoa') + 1);
|
||||||
|
EOF
|
||||||
|
|
||||||
|
while true; do
|
||||||
|
$CLICKHOUSE_CLIENT --query="SELECT count FROM dst" | grep -q "1" && break || sleep 1 ||:
|
||||||
|
done
|
||||||
|
|
||||||
|
$CLICKHOUSE_CLIENT --query="SELECT count FROM dst"
|
||||||
|
$CLICKHOUSE_CLIENT --query="DROP TABLE wv"
|
||||||
|
$CLICKHOUSE_CLIENT --query="DROP TABLE mt"
|
||||||
|
$CLICKHOUSE_CLIENT --query="DROP TABLE dst"
|
@ -1,18 +0,0 @@
|
|||||||
SET allow_experimental_window_view = 1;
|
|
||||||
|
|
||||||
DROP TABLE IF EXISTS mt;
|
|
||||||
DROP TABLE IF EXISTS dst;
|
|
||||||
DROP TABLE IF EXISTS wv;
|
|
||||||
DROP TABLE IF EXISTS `.inner.wv`;
|
|
||||||
|
|
||||||
CREATE TABLE dst(count UInt64) Engine=MergeTree ORDER BY tuple();
|
|
||||||
CREATE TABLE mt(a Int32, timestamp DateTime) ENGINE=MergeTree ORDER BY tuple();
|
|
||||||
CREATE WINDOW VIEW wv TO dst AS SELECT count(a) AS count FROM mt GROUP BY hop(timestamp, INTERVAL '1' SECOND, INTERVAL '1' SECOND, 'US/Samoa') AS wid;
|
|
||||||
|
|
||||||
INSERT INTO mt VALUES (1, now('US/Samoa') + 1);
|
|
||||||
SELECT sleep(3);
|
|
||||||
SELECT count from dst;
|
|
||||||
|
|
||||||
DROP TABLE wv;
|
|
||||||
DROP TABLE mt;
|
|
||||||
DROP TABLE dst;
|
|
Loading…
Reference in New Issue
Block a user