ClickHouse/tests/integration/test_settings_constraints_distributed/test.py

Ignoring revisions in .git-blame-ignore-revs. Click here to bypass and see the normal blame view.

188 lines
6.4 KiB
Python
Raw Normal View History

2020-01-24 14:28:10 +00:00
import pytest
from helpers.cluster import ClickHouseCluster
from helpers.test_tools import assert_eq_with_retry
cluster = ClickHouseCluster(__file__)
node1 = cluster.add_instance(
"node1",
main_configs=["configs/config.d/remote_servers.xml"],
user_configs=[
"configs/users.d/allow_introspection_functions.xml",
"configs/users.d/users.xml",
],
)
node2 = cluster.add_instance(
"node2",
main_configs=["configs/config.d/remote_servers.xml"],
user_configs=[
"configs/users.d/allow_introspection_functions.xml",
"configs/users.d/users.xml",
],
)
distributed = cluster.add_instance(
"distributed",
main_configs=["configs/config.d/remote_servers.xml"],
user_configs=[
"configs/users.d/allow_introspection_functions.xml",
"configs/users.d/users.xml",
],
stay_alive=True,
)
2020-01-24 14:28:10 +00:00
@pytest.fixture(scope="module", autouse=True)
2020-01-24 14:28:10 +00:00
def started_cluster():
try:
cluster.start()
for node in [node1, node2]:
2020-03-24 22:24:51 +00:00
node.query("CREATE USER shard")
node.query("GRANT ALL ON *.* TO shard")
2020-01-24 14:28:10 +00:00
2020-03-24 22:24:51 +00:00
distributed.query("CREATE ROLE admin")
distributed.query("GRANT ALL ON *.* TO admin")
2020-11-27 11:26:42 +00:00
distributed.query(
"CREATE TABLE shard_settings (name String, value String) ENGINE = Distributed(test_cluster, system, settings);"
)
2020-01-24 14:28:10 +00:00
yield cluster
finally:
cluster.shutdown()
@pytest.fixture(autouse=True)
def restart_distributed():
# Magic: Distributed table tries to keep connections to shards open, and after changing shards' default settings
# we need to reset connections to force the shards to reset sessions and therefore to reset current settings
# to their new defaults.
distributed.restart_clickhouse()
def test_select_clamps_settings():
2020-11-27 11:26:42 +00:00
for node in [node1, node2]:
node.query(
"CREATE TABLE sometable_select (date Date, id UInt32, value Int32) ENGINE = MergeTree() ORDER BY id;"
)
node.query("INSERT INTO sometable_select VALUES (toDate('2010-01-10'), 1, 1)")
distributed.query(
"CREATE TABLE proxy_select (date Date, id UInt32, value Int32) ENGINE = Distributed(test_cluster, default, sometable_select, toUInt64(date));"
)
2020-03-24 22:24:51 +00:00
distributed.query(
"CREATE USER normal DEFAULT ROLE admin SETTINGS max_memory_usage = 80000000"
)
distributed.query(
"CREATE USER wasteful DEFAULT ROLE admin SETTINGS max_memory_usage = 2000000000"
)
distributed.query("CREATE USER readonly DEFAULT ROLE admin SETTINGS readonly = 1")
node1.query(
"ALTER USER shard SETTINGS max_memory_usage = 50000000 MIN 11111111 MAX 99999999"
)
node2.query("ALTER USER shard SETTINGS readonly = 1")
# Check that shards doesn't throw exceptions on constraints violation
2020-11-27 11:26:42 +00:00
query = "SELECT COUNT() FROM proxy_select"
assert distributed.query(query) == "2\n"
assert distributed.query(query, user="normal") == "2\n"
assert distributed.query(query, user="wasteful") == "2\n"
assert distributed.query(query, user="readonly") == "2\n"
assert (
distributed.query(query, settings={"max_memory_usage": 40000000, "readonly": 2})
== "2\n"
)
assert (
distributed.query(
query, settings={"max_memory_usage": 3000000000, "readonly": 2}
)
== "2\n"
)
2020-01-24 14:28:10 +00:00
2020-11-27 11:26:42 +00:00
query = "SELECT COUNT() FROM remote('node{1,2}', 'default', 'sometable_select')"
assert distributed.query(query) == "2\n"
assert distributed.query(query, user="normal") == "2\n"
assert distributed.query(query, user="wasteful") == "2\n"
2020-01-24 14:28:10 +00:00
2020-03-24 22:24:51 +00:00
# Check that shards clamp passed settings.
query = "SELECT hostName() as host, name, value FROM shard_settings WHERE name = 'max_memory_usage' OR name = 'readonly' ORDER BY host, name, value"
assert (
2022-05-06 16:46:54 +00:00
distributed.query(query) == "node1\tmax_memory_usage\t50000000\n"
"node1\treadonly\t0\n"
2022-05-06 16:46:54 +00:00
"node2\tmax_memory_usage\t0\n"
"node2\treadonly\t1\n"
)
assert (
distributed.query(query, user="normal") == "node1\tmax_memory_usage\t80000000\n"
"node1\treadonly\t0\n"
2022-05-06 16:46:54 +00:00
"node2\tmax_memory_usage\t0\n"
"node2\treadonly\t1\n"
)
assert (
distributed.query(query, user="wasteful")
== "node1\tmax_memory_usage\t99999999\n"
"node1\treadonly\t0\n"
2022-05-06 16:46:54 +00:00
"node2\tmax_memory_usage\t0\n"
"node2\treadonly\t1\n"
)
assert (
distributed.query(query, user="readonly")
2022-05-06 16:46:54 +00:00
== "node1\tmax_memory_usage\t50000000\n"
"node1\treadonly\t1\n"
2022-05-06 16:46:54 +00:00
"node2\tmax_memory_usage\t0\n"
"node2\treadonly\t1\n"
)
assert (
distributed.query(query, settings={"max_memory_usage": 1})
== "node1\tmax_memory_usage\t11111111\n"
"node1\treadonly\t0\n"
2022-05-06 16:46:54 +00:00
"node2\tmax_memory_usage\t0\n"
"node2\treadonly\t1\n"
)
assert (
distributed.query(query, settings={"max_memory_usage": 40000000, "readonly": 2})
== "node1\tmax_memory_usage\t40000000\n"
"node1\treadonly\t2\n"
2022-05-06 16:46:54 +00:00
"node2\tmax_memory_usage\t0\n"
"node2\treadonly\t1\n"
)
assert (
distributed.query(
query, settings={"max_memory_usage": 3000000000, "readonly": 2}
)
== "node1\tmax_memory_usage\t99999999\n"
"node1\treadonly\t2\n"
2022-05-06 16:46:54 +00:00
"node2\tmax_memory_usage\t0\n"
"node2\treadonly\t1\n"
)
2020-03-24 22:24:51 +00:00
def test_insert_clamps_settings():
2020-11-27 11:26:42 +00:00
for node in [node1, node2]:
node.query(
"CREATE TABLE sometable_insert (date Date, id UInt32, value Int32) ENGINE = MergeTree() ORDER BY id;"
)
node.query("INSERT INTO sometable_insert VALUES (toDate('2010-01-10'), 1, 1)")
distributed.query(
"CREATE TABLE proxy_insert (date Date, id UInt32, value Int32) ENGINE = Distributed(test_cluster, default, sometable_insert, toUInt64(date));"
)
2020-03-24 22:24:51 +00:00
node1.query(
"ALTER USER shard SETTINGS max_memory_usage = 50000000 MIN 11111111 MAX 99999999"
)
node2.query(
"ALTER USER shard SETTINGS max_memory_usage = 50000000 MIN 11111111 MAX 99999999"
)
2020-11-27 11:26:42 +00:00
distributed.query("INSERT INTO proxy_insert VALUES (toDate('2020-02-20'), 2, 2)")
distributed.query(
"INSERT INTO proxy_insert VALUES (toDate('2020-02-21'), 2, 2)",
settings={"max_memory_usage": 5000000},
)
distributed.query("SYSTEM FLUSH DISTRIBUTED proxy_insert")
assert_eq_with_retry(distributed, "SELECT COUNT() FROM proxy_insert", "4")