mirror of https://github.com/citusdata/citus.git
Remove redundant pg_dist_jobid_seq restarts in tests
parent
40829c2ba9
commit
f838c83809
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_AGG_APPROXIMATE_DISTINCT
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 340000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 340000;
|
||||
-- Create HLL extension if present, print false result otherwise
|
||||
SELECT CASE WHEN COUNT(*) > 0 THEN
|
||||
'CREATE EXTENSION HLL'
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_AGG_APPROXIMATE_DISTINCT
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 340000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 340000;
|
||||
-- Create HLL extension if present, print false result otherwise
|
||||
SELECT CASE WHEN COUNT(*) > 0 THEN
|
||||
'CREATE EXTENSION HLL'
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_ARRAY_AGG
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 520000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 520000;
|
||||
CREATE OR REPLACE FUNCTION array_sort (ANYARRAY)
|
||||
RETURNS ANYARRAY LANGUAGE SQL
|
||||
AS $$
|
||||
|
|
|
@ -5,7 +5,6 @@
|
|||
-- expression, and can be anywhere in the projection order. This is in response
|
||||
-- to a bug we had due to the average expression introducing new columns.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 450000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 450000;
|
||||
SELECT
|
||||
sum(l_quantity) as sum_qty,
|
||||
sum(l_extendedprice) as sum_base_price,
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_BINARY_MASTER_COPY
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 430000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 430000;
|
||||
-- Try binary master copy for different executors
|
||||
SET citus.binary_master_copy_format TO 'on';
|
||||
SET citus.task_executor_type TO 'task-tracker';
|
||||
|
|
|
@ -4,7 +4,6 @@
|
|||
-- tests UDFs created for citus tools
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1240000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1240000;
|
||||
-- test with invalid port, prevent OS dependent warning from being displayed
|
||||
SET client_min_messages to ERROR;
|
||||
-- PG 9.5 does not show context for plpgsql raise
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1220000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1220000;
|
||||
-- Tests functions related to cluster membership
|
||||
-- before starting the test, lets try to create reference table and see a
|
||||
-- meaningful error
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1300000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1300000;
|
||||
-- ===================================================================
|
||||
-- create test utility function
|
||||
-- ===================================================================
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_COMPLEX_EXPRESSIONS
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 420000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 420000;
|
||||
-- Check that we can correctly handle complex expressions and aggregates.
|
||||
SELECT sum(l_quantity) / avg(l_quantity) FROM lineitem;
|
||||
?column?
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_COUNT_TYPE_CONVERSION
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 400000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 400000;
|
||||
-- Verify that we can sort count(*) results correctly. We perform this check as
|
||||
-- our count() operations execute in two steps: worker nodes report their
|
||||
-- count() results, and the master node sums these counts up. During this sum(),
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 390000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 390000;
|
||||
-- ===================================================================
|
||||
-- get ready for the foreign data wrapper tests
|
||||
-- ===================================================================
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 380000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 380000;
|
||||
-- ===================================================================
|
||||
-- test INSERT proxy creation functionality
|
||||
-- ===================================================================
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 370000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 370000;
|
||||
-- ===================================================================
|
||||
-- create test functions and types needed for tests
|
||||
-- ===================================================================
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_CREATE_TABLE
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 360000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 360000;
|
||||
-- Create new table definitions for use in testing in distributed planning and
|
||||
-- execution functionality. Also create indexes to boost performance.
|
||||
CREATE TABLE lineitem (
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_CREATE_TABLE_CONSTRAINTS
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 365000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 365000;
|
||||
-- test that Citus forbids unique and EXCLUDE constraints on append-partitioned tables.
|
||||
CREATE TABLE uniq_cns_append_tables
|
||||
(
|
||||
|
|
|
@ -3,7 +3,6 @@
|
|||
-- create, distribute, INSERT, SELECT and UPDATE
|
||||
-- ===================================================================
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 530000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 530000;
|
||||
-- create a custom type...
|
||||
CREATE TYPE test_composite_type AS (
|
||||
i integer,
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_DEPARSE_SHARD_QUERY
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 13100000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 13100000;
|
||||
CREATE FUNCTION deparse_shard_query_test(text)
|
||||
RETURNS VOID
|
||||
AS 'citus'
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- create test functions
|
||||
-- ===================================================================
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 540000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 540000;
|
||||
CREATE FUNCTION load_shard_id_array(regclass)
|
||||
RETURNS bigint[]
|
||||
AS 'citus'
|
||||
|
|
|
@ -3,7 +3,6 @@
|
|||
--
|
||||
-- Tests around dropping and recreating the extension
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 550000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 550000;
|
||||
CREATE TABLE testtableddl(somecol int, distributecol text NOT NULL);
|
||||
SELECT master_create_distributed_table('testtableddl', 'distributecol', 'append');
|
||||
master_create_distributed_table
|
||||
|
|
|
@ -1,7 +1,6 @@
|
|||
-- Tests that check that our query functionality behaves as expected when the
|
||||
-- table schema is modified via ALTER statements.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 620000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 620000;
|
||||
SELECT count(*) FROM customer;
|
||||
count
|
||||
-------
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
--- MULTI_EXPIRE_TABLE_CACHE
|
||||
---
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1220000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1220000;
|
||||
-- create test table
|
||||
CREATE TABLE large_table(a int, b int);
|
||||
SELECT master_create_distributed_table('large_table', 'a', 'hash');
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_EXPLAIN
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 570000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 570000;
|
||||
-- print major version to make version-specific tests clear
|
||||
SELECT substring(version(), '\d+\.\d+') AS major_version;
|
||||
major_version
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_FOREIGN_KEY
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1350000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1350000;
|
||||
-- set shard_count to 4 for faster tests, because we create/drop lots of shards in this test.
|
||||
SET citus.shard_count TO 4;
|
||||
-- create tables
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_FUNCTION_EVALUATION
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1200000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1200000;
|
||||
-- nextval() works (no good way to test DEFAULT, or, by extension, SERIAL)
|
||||
CREATE TABLE example (key INT, value INT);
|
||||
SELECT master_create_distributed_table('example', 'key', 'hash');
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 610000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 610000;
|
||||
-- ===================================================================
|
||||
-- create test functions
|
||||
-- ===================================================================
|
||||
|
|
|
@ -3,7 +3,6 @@
|
|||
--
|
||||
-- Tests for shard and join pruning logic on hash partitioned tables.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 630000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 630000;
|
||||
-- Create a table partitioned on integer column and update partition type to
|
||||
-- hash. Then load data into this table and update shard min max values with
|
||||
-- hashed ones. Hash value of 1, 2, 3 and 4 are consecutively -1905060026,
|
||||
|
|
|
@ -4,7 +4,6 @@
|
|||
-- Check that we can run CREATE INDEX and DROP INDEX statements on distributed
|
||||
-- tables.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 640000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 640000;
|
||||
--
|
||||
-- CREATE TEST TABLES
|
||||
--
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_INSERT_SELECT
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 13300000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 13300000;
|
||||
-- create co-located tables
|
||||
SET citus.shard_count = 4;
|
||||
SET citus.shard_replication_factor = 2;
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_JOIN_ORDER_ADDITIONAL
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 650000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 650000;
|
||||
-- Set configuration to print table join order and pruned shards
|
||||
SET citus.explain_distributed_queries TO off;
|
||||
SET citus.log_multi_join_order TO TRUE;
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_JOIN_ORDER_TPCH_LARGE
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 660000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 660000;
|
||||
-- Enable configuration to print table join order
|
||||
SET citus.explain_distributed_queries TO off;
|
||||
SET citus.log_multi_join_order TO TRUE;
|
||||
|
|
|
@ -1,7 +1,6 @@
|
|||
--
|
||||
-- MULTI_JOIN_PRUNING
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 680000;
|
||||
-- Check that join-pruning works for joins between two large relations. For now
|
||||
-- we only check for join-pruning between locally partitioned relations. In the
|
||||
-- future we want to check for pruning between re-partitioned relations as well.
|
||||
|
|
|
@ -5,7 +5,6 @@
|
|||
-- set executor type to task tracker executor here, as we cannot run repartition
|
||||
-- jobs with real time executor.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 700000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 700000;
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
SET client_min_messages TO DEBUG2;
|
||||
SET citus.task_executor_type TO 'task-tracker';
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_LIMIT_CLAUSE
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 730000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 730000;
|
||||
-- Display debug messages on limit clause push down.
|
||||
SET client_min_messages TO DEBUG1;
|
||||
-- Check that we can correctly handle the Limit clause in distributed queries.
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_LIMIT_CLAUSE_APPROXIMATE
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 720000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 720000;
|
||||
-- Display debug messages on limit clause push down.
|
||||
SET client_min_messages TO DEBUG1;
|
||||
-- We first look at results with limit optimization disabled. This first query
|
||||
|
|
|
@ -3,7 +3,6 @@
|
|||
--
|
||||
-- Tests that check the metadata returned by the master node.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 740000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 740000;
|
||||
SELECT part_storage_type, part_key, part_replica_count, part_max_size,
|
||||
part_placement_policy FROM master_get_table_metadata('lineitem');
|
||||
part_storage_type | part_key | part_replica_count | part_max_size | part_placement_policy
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_METADATA_ACCESS
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1360000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1360000;
|
||||
CREATE USER no_access;
|
||||
NOTICE: not propagating CREATE ROLE/USER commands to worker nodes
|
||||
HINT: Connect to worker nodes directly to manually create all necessary users and roles.
|
||||
|
|
|
@ -4,7 +4,6 @@
|
|||
-- Tests for metadata snapshot functions, metadata syncing functions and propagation of
|
||||
-- metadata changes to MX tables.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1310000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1310000;
|
||||
SELECT nextval('pg_catalog.pg_dist_shard_placement_placementid_seq') AS last_placement_id
|
||||
\gset
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shard_placement_placementid_seq RESTART 100000;
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 750000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 750000;
|
||||
-- ===================================================================
|
||||
-- test end-to-end modification functionality
|
||||
-- ===================================================================
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1200000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1200000;
|
||||
-- ===================================================================
|
||||
-- test end-to-end modification functionality
|
||||
-- ===================================================================
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_MX_CREATE_TABLE
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1220000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1220000;
|
||||
SELECT start_metadata_sync_to_node('localhost', :worker_1_port);
|
||||
start_metadata_sync_to_node
|
||||
-----------------------------
|
||||
|
|
|
@ -1,6 +1,5 @@
|
|||
-- Tests related to distributed DDL commands on mx cluster
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1600000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1600000;
|
||||
SELECT * FROM mx_ddl_table ORDER BY key;
|
||||
key | value
|
||||
-----+-------
|
||||
|
|
|
@ -2,11 +2,8 @@
|
|||
-- MULTI_MX_EXPLAIN
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1320000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1320000;
|
||||
\c - - - :worker_1_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1320000;
|
||||
\c - - - :worker_2_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1320000;
|
||||
\c - - - :master_port
|
||||
\a\t
|
||||
SET citus.task_executor_type TO 'real-time';
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1330000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1330000;
|
||||
-- ===================================================================
|
||||
-- test end-to-end modification functionality for mx tables
|
||||
-- ===================================================================
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1340000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1340000;
|
||||
-- ===================================================================
|
||||
-- test end-to-end modification functionality for mx tables in transactions
|
||||
-- ===================================================================
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1250000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1250000;
|
||||
\c - - - :master_port
|
||||
CREATE TABLE reference_table_test (value_1 int, value_2 float, value_3 text, value_4 timestamp);
|
||||
SELECT create_reference_table('reference_table_test');
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 840000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 840000;
|
||||
-- ===================================================================
|
||||
-- test router planner functionality for single shard select queries
|
||||
-- ===================================================================
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_MX_SCHEMA_SUPPORT
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1210000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1210000;
|
||||
-- connect to a worker node and run some queries
|
||||
\c - - - :worker_1_port
|
||||
-- test very basic queries
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_MX_TPCH_QUERY1
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1310000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1310000;
|
||||
-- connect to the coordinator
|
||||
\c - - - :master_port
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
|
@ -40,7 +39,6 @@ ORDER BY
|
|||
-- connect one of the workers
|
||||
\c - - - :worker_1_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1310000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1310000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #1 from the TPC-H decision support benchmark
|
||||
|
@ -76,7 +74,6 @@ ORDER BY
|
|||
-- connect to the other node
|
||||
\c - - - :worker_2_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1310000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1310000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #1 from the TPC-H decision support benchmark
|
||||
|
|
|
@ -5,7 +5,6 @@
|
|||
-- we don't set citus.large_table_shard_count here, and instead use the default value
|
||||
-- coming from postgresql.conf or multi_task_tracker_executor.conf.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1300000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1300000;
|
||||
-- connect to master
|
||||
\c - - - :master_port
|
||||
SELECT
|
||||
|
@ -67,7 +66,6 @@ LIMIT 20;
|
|||
-- connect one of the workers
|
||||
\c - - - :worker_1_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1300000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1300000;
|
||||
SELECT
|
||||
c_custkey,
|
||||
c_name,
|
||||
|
@ -127,7 +125,6 @@ LIMIT 20;
|
|||
-- connect to the other worker
|
||||
\c - - - :worker_2_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1300000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1300000;
|
||||
SELECT
|
||||
c_custkey,
|
||||
c_name,
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_MX_TPCH_QUERY12
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1290000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1290000;
|
||||
-- connect to the coordinator
|
||||
\c - - - :master_port
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
|
@ -45,7 +44,6 @@ ORDER BY
|
|||
-- connect one of the workers
|
||||
\c - - - :worker_1_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1290000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1290000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #12 from the TPC-H decision support benchmark
|
||||
|
@ -86,7 +84,6 @@ ORDER BY
|
|||
-- connect to the other worker node
|
||||
\c - - - :worker_2_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1290000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1290000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #12 from the TPC-H decision support benchmark
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_MX_TPCH_QUERY14
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1280000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1280000;
|
||||
-- connect to the coordinator
|
||||
\c - - - :master_port
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
|
@ -29,7 +28,6 @@ WHERE
|
|||
-- connect one of the workers
|
||||
\c - - - :worker_1_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1280000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1280000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #14 from the TPC-H decision support benchmark
|
||||
|
@ -54,7 +52,6 @@ WHERE
|
|||
-- connect to the other node
|
||||
\c - - - :worker_2_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1280000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1280000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #14 from the TPC-H decision support benchmark
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_MX_TPCH_QUERY19
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1270000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1270000;
|
||||
-- connect to the coordinator
|
||||
\c - - - :master_port
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
|
@ -46,7 +45,6 @@ WHERE
|
|||
-- connect one of the workers
|
||||
\c - - - :worker_1_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1270000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1270000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #19 from the TPC-H decision support benchmark. Note that we modified
|
||||
|
@ -88,7 +86,6 @@ WHERE
|
|||
-- connect to the other node
|
||||
\c - - - :worker_2_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1270000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1270000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #19 from the TPC-H decision support benchmark. Note that we modified
|
||||
|
|
|
@ -5,7 +5,6 @@
|
|||
-- we don't set citus.large_table_shard_count here, and instead use the default value
|
||||
-- coming from postgresql.conf or multi_task_tracker_executor.conf.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1260000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1260000;
|
||||
-- connect to the coordinator
|
||||
\c - - - :master_port
|
||||
SELECT
|
||||
|
@ -53,7 +52,6 @@ ORDER BY
|
|||
-- connect one of the workers
|
||||
\c - - - :worker_1_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1260000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1260000;
|
||||
SELECT
|
||||
l_orderkey,
|
||||
sum(l_extendedprice * (1 - l_discount)) as revenue,
|
||||
|
@ -99,7 +97,6 @@ ORDER BY
|
|||
-- connect to the other node
|
||||
\c - - - :worker_2_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1260000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1260000;
|
||||
SELECT
|
||||
l_orderkey,
|
||||
sum(l_extendedprice * (1 - l_discount)) as revenue,
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_MX_TPCH_QUERY6
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1250000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1250000;
|
||||
-- connect to the coordinator
|
||||
\c - - - :master_port
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
|
@ -25,7 +24,6 @@ WHERE
|
|||
-- connect to one of the worker nodes
|
||||
\c - - - :worker_1_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1250000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1250000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #6 from the TPC-H decision support benchmark
|
||||
|
@ -46,7 +44,6 @@ WHERE
|
|||
-- connect to the other worker node
|
||||
\c - - - :worker_2_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1250000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1250000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #6 from the TPC-H decision support benchmark
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_MX_TPCH_QUERY7
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1230000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1230000;
|
||||
-- connect to the coordinator
|
||||
\c - - - :master_port
|
||||
-- Change configuration to treat lineitem AND orders tables as large
|
||||
|
@ -55,7 +54,6 @@ ORDER BY
|
|||
-- connect one of the workers
|
||||
\c - - - :worker_1_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1230000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1230000;
|
||||
-- Change configuration to treat lineitem AND orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #7 from the TPC-H decision support benchmark
|
||||
|
@ -106,7 +104,6 @@ ORDER BY
|
|||
-- connect to the other worker node
|
||||
\c - - - :worker_2_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1230000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1230000;
|
||||
-- Change configuration to treat lineitem AND orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #7 from the TPC-H decision support benchmark
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_MX_TPCH_QUERY7_NESTED
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1240000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1240000;
|
||||
-- connect to the coordinator
|
||||
\c - - - :master_port
|
||||
-- Change configuration to treat lineitem AND orders tables AS large
|
||||
|
@ -64,7 +63,6 @@ ORDER BY
|
|||
-- connect to one of the workers
|
||||
\c - - - :worker_1_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1240000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1240000;
|
||||
-- Change configuration to treat lineitem AND orders tables AS large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #7 from the TPC-H benchmark; modified to include sub-selects
|
||||
|
@ -124,7 +122,6 @@ ORDER BY
|
|||
-- connect to the coordinator
|
||||
\c - - - :worker_2_port
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1240000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1240000;
|
||||
-- Change configuration to treat lineitem AND orders tables AS large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #7 from the TPC-H benchmark; modified to include sub-selects
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_NAME_LENGTHS
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 225000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 225000;
|
||||
SET citus.multi_shard_commit_protocol = '2pc';
|
||||
-- Verify that a table name > 56 characters gets hashed properly.
|
||||
CREATE TABLE too_long_12345678901234567890123456789012345678901234567890 (
|
||||
|
|
|
@ -4,7 +4,6 @@
|
|||
-- This test checks that we can handle null min/max values in shard statistics
|
||||
-- and that we don't partition or join prune shards that have null values.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 760000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 760000;
|
||||
SET client_min_messages TO DEBUG2;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
|
|
|
@ -4,7 +4,6 @@
|
|||
-- Tests to verify that we correctly prune unreferenced shards. For this, we
|
||||
-- need to increase the logging verbosity of messages displayed on the client.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 770000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 770000;
|
||||
SET citus.explain_distributed_queries TO off;
|
||||
SET client_min_messages TO DEBUG2;
|
||||
-- Adding additional l_orderkey = 1 to make this query not router executable
|
||||
|
|
|
@ -5,7 +5,6 @@
|
|||
-- and converted into both plain SQL and PL/pgsql functions, which
|
||||
-- use prepared statements internally.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 780000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 780000;
|
||||
CREATE FUNCTION plpgsql_test_1() RETURNS TABLE(count bigint) AS $$
|
||||
DECLARE
|
||||
BEGIN
|
||||
|
|
|
@ -5,7 +5,6 @@
|
|||
-- taken from other regression test files and converted into
|
||||
-- prepared statements.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 790000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 790000;
|
||||
PREPARE prepared_test_1 AS
|
||||
SELECT
|
||||
count(*)
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 800000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 800000;
|
||||
-- ===================================================================
|
||||
-- create test functions
|
||||
-- ===================================================================
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1250000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1250000;
|
||||
CREATE TABLE reference_table_test (value_1 int, value_2 float, value_3 text, value_4 timestamp);
|
||||
-- insert some data, and make sure that cannot be create_distributed_table
|
||||
INSERT INTO reference_table_test VALUES (1, 1.0, '1', '2016-12-01');
|
||||
|
|
|
@ -3,7 +3,6 @@
|
|||
--
|
||||
-- Tests that check the metadata after master_remove_node.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1380000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1380000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_colocationid_seq RESTART 1380000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_groupid_seq RESTART 1380000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_node_nodeid_seq RESTART 1380000;
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 820000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 820000;
|
||||
-- ===================================================================
|
||||
-- test shard repair functionality
|
||||
-- ===================================================================
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_REPARTITIONED_SUBQUERY_UDF
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 830000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 830000;
|
||||
-- Create UDF in master and workers
|
||||
\c - - - :master_port
|
||||
DROP FUNCTION IF EXISTS median(double precision[]);
|
||||
|
|
|
@ -3,7 +3,6 @@
|
|||
--
|
||||
-- Tests that check the metadata returned by the master node.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1370000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1370000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_colocationid_seq RESTART 1370000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_groupid_seq RESTART 1370000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_node_nodeid_seq RESTART 1370000;
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_SCHEMA_SUPPORT
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1190000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1190000;
|
||||
-- create schema to test schema support
|
||||
CREATE SCHEMA test_schema_support;
|
||||
-- test master_append_table_to_shard with schema
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_SHARD_MODIFY
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 350000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 350000;
|
||||
-- Create a new hash partitioned multi_shard_modify_test table and load data into it.
|
||||
CREATE TABLE multi_shard_modify_test (
|
||||
t_key integer not null,
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 850000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 850000;
|
||||
-- ===================================================================
|
||||
-- test end-to-end query functionality
|
||||
-- ===================================================================
|
||||
|
|
|
@ -3,7 +3,6 @@
|
|||
--
|
||||
-- This test checks that we are able to run selected set of distributed SQL subqueries.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 860000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 860000;
|
||||
SET citus.task_executor_type TO 'task-tracker';
|
||||
select
|
||||
number_sum,
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_SQL_FUNCTION
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1230000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1230000;
|
||||
CREATE FUNCTION sql_test_no_1() RETURNS bigint AS '
|
||||
SELECT
|
||||
count(*)
|
||||
|
|
|
@ -3,7 +3,6 @@
|
|||
--
|
||||
-- Tests around changing the schema and dropping of a distributed table
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 870000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 870000;
|
||||
CREATE TABLE testtableddl(somecol int, distributecol text NOT NULL);
|
||||
SELECT master_create_distributed_table('testtableddl', 'distributecol', 'append');
|
||||
master_create_distributed_table
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_TPCH_QUERY1
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 890000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 890000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #1 from the TPC-H decision support benchmark
|
||||
|
|
|
@ -5,7 +5,6 @@
|
|||
-- we don't set citus.large_table_shard_count here, and instead use the default value
|
||||
-- coming from postgresql.conf or multi_task_tracker_executor.conf.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 900000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 900000;
|
||||
SELECT
|
||||
c_custkey,
|
||||
c_name,
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_TPCH_QUERY12
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 910000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 910000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #12 from the TPC-H decision support benchmark
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_TPCH_QUERY14
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 920000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 920000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #14 from the TPC-H decision support benchmark
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_TPCH_QUERY19
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 930000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 930000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #19 from the TPC-H decision support benchmark. Note that we modified
|
||||
|
|
|
@ -5,7 +5,6 @@
|
|||
-- we don't set citus.large_table_shard_count here, and instead use the default value
|
||||
-- coming from postgresql.conf or multi_task_tracker_executor.conf.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 940000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 940000;
|
||||
SELECT
|
||||
l_orderkey,
|
||||
sum(l_extendedprice * (1 - l_discount)) as revenue,
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_TPCH_QUERY6
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 950000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 950000;
|
||||
-- Change configuration to treat lineitem and orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #6 from the TPC-H decision support benchmark
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_TPCH_QUERY7
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 970000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 970000;
|
||||
-- Change configuration to treat lineitem AND orders tables as large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #7 from the TPC-H decision support benchmark
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_TPCH_QUERY7_NESTED
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 960000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 960000;
|
||||
-- Change configuration to treat lineitem AND orders tables AS large
|
||||
SET citus.large_table_shard_count TO 2;
|
||||
-- Query #7 from the TPC-H benchmark; modified to include sub-selects
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1220000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1220000;
|
||||
-- Tests for prepared transaction recovery
|
||||
-- Ensure pg_dist_transaction is empty for test
|
||||
SELECT recover_prepared_transactions();
|
||||
|
|
|
@ -3,7 +3,6 @@
|
|||
--
|
||||
-- Tests that check the metadata returned by the master node.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1410000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1410000;
|
||||
SET citus.shard_count TO 4;
|
||||
-- test DROP TABLE(ergo master_drop_all_shards) in transaction, then ROLLBACK
|
||||
CREATE TABLE transactional_drop_shards(column1 int);
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- MULTI_TRUNCATE
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1210000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1210000;
|
||||
--
|
||||
-- truncate for append distribution
|
||||
-- expect all shards to be dropped
|
||||
|
|
|
@ -3,7 +3,6 @@
|
|||
--
|
||||
-- Tests for ensuring unsupported functions on workers error out.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1270000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1270000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_groupid_seq RESTART 1370000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_node_nodeid_seq RESTART 1370000;
|
||||
-- Set the colocation id to a safe value so that
|
||||
|
|
|
@ -4,7 +4,6 @@
|
|||
-- Tests around upgrade_reference_table UDF
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1360000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1360000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_colocationid_seq RESTART 1360000;
|
||||
-- test with not distributed table
|
||||
CREATE TABLE upgrade_reference_table_local(column1 int);
|
||||
|
|
|
@ -1,6 +1,5 @@
|
|||
-- this test file aims to test UPSERT feature on Citus
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 980000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 980000;
|
||||
CREATE TABLE upsert_test
|
||||
(
|
||||
part_key int UNIQUE,
|
||||
|
|
|
@ -1,5 +1,4 @@
|
|||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 990000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 990000;
|
||||
-- ===================================================================
|
||||
-- test utility statement functionality
|
||||
-- ===================================================================
|
||||
|
|
|
@ -5,7 +5,6 @@
|
|||
-- distributed tables. Currently we only support CREATE TABLE AS (SELECT..),
|
||||
-- DECLARE CURSOR, and COPY ... TO statements.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1000000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1000000;
|
||||
CREATE TEMP TABLE lineitem_pricing_summary AS
|
||||
(
|
||||
SELECT
|
||||
|
|
|
@ -4,7 +4,6 @@
|
|||
-- Tests to check if we inform the user about potential caveats of creating new
|
||||
-- databases, schemas, and roles.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1010000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1010000;
|
||||
CREATE DATABASE new_database;
|
||||
NOTICE: Citus partially supports CREATE DATABASE for distributed databases
|
||||
DETAIL: Citus does not propagate CREATE DATABASE command to workers
|
||||
|
|
|
@ -6,7 +6,6 @@
|
|||
-- these columns are pulled to the master, and are correctly used in sorting and
|
||||
-- grouping.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1040000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1040000;
|
||||
SELECT l_quantity FROM lineitem ORDER BY l_shipdate, l_quantity LIMIT 20;
|
||||
l_quantity
|
||||
------------
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- TASK_TRACKER_ASSIGN_TASK
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1050000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1050000;
|
||||
\set JobId 401010
|
||||
\set SimpleTaskId 101101
|
||||
\set RecoverableTaskId 801102
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- TASK_TRACKER_CLEANUP_JOB
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1060000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1060000;
|
||||
\set JobId 401010
|
||||
\set CompletedTaskId 801107
|
||||
\set RunningTaskId 801108
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- TASK_TRACKER_CREATE_TABLE
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1070000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1070000;
|
||||
-- New table definitions to test the task tracker process and protocol
|
||||
CREATE TABLE lineitem_simple_task ( LIKE lineitem );
|
||||
CREATE TABLE lineitem_compute_task ( LIKE lineitem );
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- TASK_TRACKER_PARTITION_TASK
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1080000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1080000;
|
||||
\set JobId 401010
|
||||
\set PartitionTaskId 801106
|
||||
\set PartitionColumn l_orderkey
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- WORKER_BINARY_DATA_PARTITION
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1090000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1090000;
|
||||
\set JobId 201010
|
||||
\set TaskId 101105
|
||||
\set Partition_Column textcolumn
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- WORKER_CHECK_INVALID_ARGUMENTS
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1100000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1100000;
|
||||
\set JobId 201010
|
||||
\set TaskId 101108
|
||||
\set Table_Name simple_binary_data_table
|
||||
|
|
|
@ -5,7 +5,6 @@
|
|||
-- node execution logic. For now,the tests include range and hash partitioning
|
||||
-- of existing tables.
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1110000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1110000;
|
||||
CREATE TABLE lineitem (
|
||||
l_orderkey bigint not null,
|
||||
l_partkey integer not null,
|
||||
|
|
|
@ -2,7 +2,6 @@
|
|||
-- WORKER_HASH_PARTITION
|
||||
--
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_shardid_seq RESTART 1130000;
|
||||
ALTER SEQUENCE pg_catalog.pg_dist_jobid_seq RESTART 1130000;
|
||||
\set JobId 201010
|
||||
\set TaskId 101103
|
||||
\set Partition_Column l_orderkey
|
||||
|
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue