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

Notice when replicating reference tables.

guc_for_replicate_on_activate
Hadi Moshayedi 2020-04-07 10:27:20 -07:00
parent 1171ca7f1f
commit 601c2d6e54
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/backend/distributed/utils/reference_table_utils.c
View File

@ -136,12 +136,13 @@ EnsureReferenceTablesExistOnAllNodes(void)
} }
Oid referenceTableId = linitial_oid(referenceTableIdList); Oid referenceTableId = linitial_oid(referenceTableIdList);
const char *referenceTableName = get_rel_name(referenceTableId);
List *shardIntervalList = LoadShardIntervalList(referenceTableId); List *shardIntervalList = LoadShardIntervalList(referenceTableId);
if (list_length(shardIntervalList) == 0) if (list_length(shardIntervalList) == 0)
{ {
/* check for corrupt metadata */ /* check for corrupt metadata */
ereport(ERROR, (errmsg("reference table \"%s\" does not have a shard", ereport(ERROR, (errmsg("reference table \"%s\" does not have a shard",
get_rel_name(referenceTableId)))); referenceTableName)));
} }
ShardInterval *shardInterval = (ShardInterval *) linitial(shardIntervalList); ShardInterval *shardInterval = (ShardInterval *) linitial(shardIntervalList);
@ -199,6 +200,10 @@ EnsureReferenceTablesExistOnAllNodes(void)
WorkerNode *newWorkerNode = NULL; WorkerNode *newWorkerNode = NULL;
foreach_ptr(newWorkerNode, newWorkersList) foreach_ptr(newWorkerNode, newWorkersList)
{ {
ereport(NOTICE, (errmsg("replicating reference table '%s' to %s:%d ...",
referenceTableName, newWorkerNode->workerName,
newWorkerNode->workerPort)));
/* /*
* Call master_copy_shard_placement using citus extension owner. Current * Call master_copy_shard_placement using citus extension owner. Current
* user might not have permissions to do the copy. * user might not have permissions to do the copy.

3
src/test/regress/bin/normalize.sed
View File

@ -111,3 +111,6 @@ s/worker_hash_partition_table \([0-9]+/worker_hash_partition_table \(xxxxxxx/g
# ignore first parameter for citus_extradata_container due to differences between pg11 and pg12 # ignore first parameter for citus_extradata_container due to differences between pg11 and pg12
# can be removed when we remove PG_VERSION_NUM >= 120000 # can be removed when we remove PG_VERSION_NUM >= 120000
s/pg_catalog.citus_extradata_container\([0-9]+/pg_catalog.citus_extradata_container\(XXX/g s/pg_catalog.citus_extradata_container\([0-9]+/pg_catalog.citus_extradata_container\(XXX/g
# ignore referene table replication messages
/replicating reference table.*$/d