From 09cfb24b16524981b40694e06afb42c9e0e18099 Mon Sep 17 00:00:00 2001 From: Burak Velioglu Date: Thu, 20 Jan 2022 00:13:58 +0300 Subject: [PATCH] Update should sync check src/backend/distributed/test/distributed_intermediate_results-29ca979d.o.tmp --- src/backend/distributed/metadata/metadata_sync.c | 8 -------- src/test/regress/input/multi_copy.source | 2 ++ 2 files changed, 2 insertions(+), 8 deletions(-) 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;