diff --git a/src/backend/distributed/metadata/node_metadata.c b/src/backend/distributed/metadata/node_metadata.c index e87848ed8..ec0f8e2c2 100644 --- a/src/backend/distributed/metadata/node_metadata.c +++ b/src/backend/distributed/metadata/node_metadata.c @@ -708,6 +708,7 @@ master_update_node(PG_FUNCTION_ARGS) UpdateNodeLocation(nodeId, newNodeNameString, newNodePort); + /* we should be able to find the new node from the metadata */ workerNode = FindWorkerNode(newNodeNameString, newNodePort); Assert(workerNode->nodeId == nodeId);