diff --git a/src/backend/distributed/commands/utility_hook.c b/src/backend/distributed/commands/utility_hook.c index a054b7a6b..c03df95e2 100644 --- a/src/backend/distributed/commands/utility_hook.c +++ b/src/backend/distributed/commands/utility_hook.c @@ -53,6 +53,7 @@ #include "distributed/multi_explain.h" #include "distributed/multi_physical_planner.h" #include "distributed/resource_lock.h" +#include "distributed/shared_connection_stats.h" #include "distributed/transmit.h" #include "distributed/version_compat.h" #include "distributed/worker_transaction.h" @@ -63,7 +64,6 @@ #include "utils/builtins.h" #include "utils/lsyscache.h" #include "utils/syscache.h" -#include "distributed/shared_connection_stats.h" bool EnableDDLPropagation = true; /* ddl propagation is enabled */ PropSetCmdBehavior PropagateSetCommands = PROPSETCMD_NONE; /* SET prop off */ diff --git a/src/backend/distributed/connection/shared_connection_stats.c b/src/backend/distributed/connection/shared_connection_stats.c index d44946b82..7d204a8db 100644 --- a/src/backend/distributed/connection/shared_connection_stats.c +++ b/src/backend/distributed/connection/shared_connection_stats.c @@ -209,7 +209,8 @@ RemoveInactiveNodesFromSharedConnections(void) while ((connectionEntry = (SharedConnStatsHashEntry *) hash_seq_search(&status)) != 0) { SharedConnStatsHashKey connectionKey = connectionEntry->key; - WorkerNode *workerNode = FindWorkerNode(connectionKey.hostname, connectionKey.port); + WorkerNode *workerNode = FindWorkerNode(connectionKey.hostname, + connectionKey.port); if (workerNode == NULL || !workerNode->isActive) {