diff --git a/src/backend/distributed/operations/worker_node_manager.c b/src/backend/distributed/operations/worker_node_manager.c index a1637bf34..5d3a9f824 100644 --- a/src/backend/distributed/operations/worker_node_manager.c +++ b/src/backend/distributed/operations/worker_node_manager.c @@ -318,20 +318,6 @@ ActivePrimaryNodeCount(void) } -/* - * ActiveReadableNonCoordinatorNodeCount returns the number of groups with a node we can read from. - * This method excludes coordinator even if it is added as a worker. - */ -uint32 -ActiveReadableNonCoordinatorNodeCount(void) -{ - List *workerNodeList = ActiveReadableNonCoordinatorNodeList(); - uint32 liveWorkerCount = list_length(workerNodeList); - - return liveWorkerCount; -} - - /* * NodeIsCoordinator returns true if the given node represents the coordinator. */ diff --git a/src/include/distributed/worker_manager.h b/src/include/distributed/worker_manager.h index db0045166..776e7b292 100644 --- a/src/include/distributed/worker_manager.h +++ b/src/include/distributed/worker_manager.h @@ -80,7 +80,6 @@ extern WorkerNode * CoordinatorNodeIfAddedAsWorkerOrError(void); extern void ErrorIfCoordinatorNotAddedAsWorkerNode(void); extern List * DistributedTablePlacementNodeList(LOCKMODE lockMode); extern bool NodeCanHaveDistTablePlacements(WorkerNode *node); -extern uint32 ActiveReadableNonCoordinatorNodeCount(void); extern List * ActiveReadableNonCoordinatorNodeList(void); extern List * ActiveReadableNodeList(void); extern WorkerNode * FindWorkerNode(const char *nodeName, int32 nodePort);