external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update multiple table integration sync

velioglu/wo_seq_test_1
Burak Velioglu 2022-01-07 12:18:06 +03:00
parent 299043dfaa
commit 1383c442ea
No known key found for this signature in database
GPG Key ID: F6827E620F6549C6
4 changed files with 310 additions and 361 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/metadata/node_metadata.c
View File

@ -895,6 +895,7 @@ SetUpDistributedTableWithDependencies(WorkerNode *newWorkerNode)
PropagateNodeWideObjects(newWorkerNode); PropagateNodeWideObjects(newWorkerNode);
ReplicateAllDependenciesToNode(newWorkerNode->workerName, ReplicateAllDependenciesToNode(newWorkerNode->workerName,
newWorkerNode->workerPort); newWorkerNode->workerPort);
SetUpMultipleDistributedTableIntegrations(newWorkerNode);
} }
if (ReplicateReferenceTablesOnActivate) if (ReplicateReferenceTablesOnActivate)
@ -1208,7 +1209,6 @@ ActivateNode(char *nodeName, int nodePort)
} }
SetUpDistributedTableWithDependencies(workerNode); SetUpDistributedTableWithDependencies(workerNode);
SetUpMultipleDistributedTableIntegrations(workerNode);
if (syncMetadata) if (syncMetadata)
{ {

662
src/test/regress/expected/multi_cluster_management.out
View File

File diff suppressed because it is too large Load Diff

1
src/test/regress/sql/multi_cluster_management.sql
View File

@ -79,7 +79,6 @@ SELECT master_get_active_worker_nodes();
SELECT citus_disable_node('localhost.noexist', 2345); SELECT citus_disable_node('localhost.noexist', 2345);
-- drop the table without leaving a shard placement behind (messes up other tests) -- drop the table without leaving a shard placement behind (messes up other tests)
-- TODO: Replication ref table multiple times
SELECT master_activate_node('localhost', :worker_2_port); SELECT master_activate_node('localhost', :worker_2_port);
DROP TABLE test_reference_table, cluster_management_test; DROP TABLE test_reference_table, cluster_management_test;

6
src/test/regress/sql/single_node.sql
View File

@ -4,10 +4,6 @@ SET citus.shard_count TO 4;
SET citus.shard_replication_factor TO 1; SET citus.shard_replication_factor TO 1;
SET citus.next_shard_id TO 90630500; SET citus.next_shard_id TO 90630500;
table pg_dist_node;
table pg_dist_partition;
\d
-- Ensure tuple data in explain analyze output is the same on all PG versions -- Ensure tuple data in explain analyze output is the same on all PG versions
SET citus.enable_binary_protocol = TRUE; SET citus.enable_binary_protocol = TRUE;
@ -82,10 +78,8 @@ SELECT 1 FROM master_remove_node('localhost', :worker_1_port);
SELECT 1 FROM citus_set_coordinator_host('127.0.0.1'); SELECT 1 FROM citus_set_coordinator_host('127.0.0.1');
-- adding workers with specific IP is ok now -- adding workers with specific IP is ok now
set citus.log_remote_commands to true;
SELECT 1 FROM master_add_node('127.0.0.1', :worker_1_port); SELECT 1 FROM master_add_node('127.0.0.1', :worker_1_port);
SELECT 1 FROM master_remove_node('127.0.0.1', :worker_1_port); SELECT 1 FROM master_remove_node('127.0.0.1', :worker_1_port);
reset citus.log_remote_commands;
-- set the coordinator host back to localhost for the remainder of tests -- set the coordinator host back to localhost for the remainder of tests
SELECT 1 FROM citus_set_coordinator_host('localhost'); SELECT 1 FROM citus_set_coordinator_host('localhost');