Remove metadata object from ref table prop

velioglu/wo_seq_test_1
Burak Velioglu 2021-12-21 22:27:36 +03:00
parent 9fec89d70b
commit 50f52101b8
No known key found for this signature in database
GPG Key ID: F6827E620F6549C6
1 changed files with 3 additions and 8 deletions

View File

@ -379,14 +379,9 @@ ReplicateShardToNode(ShardInterval *shardInterval, char *nodeName, int nodePort)
InsertShardPlacementRow(shardId, placementId, SHARD_STATE_ACTIVE, 0, InsertShardPlacementRow(shardId, placementId, SHARD_STATE_ACTIVE, 0,
groupId); groupId);
if (ShouldSyncTableMetadata(shardInterval->relationId)) // Since having a duplicate on pg_dist_placement can cause issue, we don't add
{ // it to all nodes here. Caller of this function must propagate pg_dist_placement to
char *placementCommand = PlacementUpsertCommand(shardId, placementId, // other nodes if it is required.
SHARD_STATE_ACTIVE, 0,
groupId);
SendCommandToWorkersWithMetadata(placementCommand);
}
} }