diff --git a/src/backend/distributed/metadata/metadata_sync.c b/src/backend/distributed/metadata/metadata_sync.c index be3381d43..cbe1b6526 100644 --- a/src/backend/distributed/metadata/metadata_sync.c +++ b/src/backend/distributed/metadata/metadata_sync.c @@ -404,14 +404,6 @@ ShouldSyncTableMetadata(Oid relationId) bool citusTableWithNoDistKey = IsCitusTableTypeCacheEntry(tableEntry, CITUS_TABLE_WITH_NO_DIST_KEY); - /* - * We shouldn't sync metadata for distributed tables created with master_create_distributed_table - */ - if (hashDistributed && tableEntry->colocationId == INVALID_COLOCATION_ID) - { - return false; - } - return ShouldSyncTableMetadataInternal(hashDistributed, citusTableWithNoDistKey); } diff --git a/src/test/regress/input/multi_copy.source b/src/test/regress/input/multi_copy.source index b40cdd2d5..fe9fee121 100644 --- a/src/test/regress/input/multi_copy.source +++ b/src/test/regress/input/multi_copy.source @@ -497,6 +497,8 @@ SELECT shardid, nodename, nodeport WHERE logicalrelid = 'numbers_append'::regclass order by placementid; -- add the node back +set citus.log_remote_commands to true; +set citus.worker_min_messages to debug4; SELECT 1 FROM master_activate_node('localhost', :worker_1_port); RESET client_min_messages; RESET citus.shard_replication_factor;