diff --git a/src/backend/distributed/transaction/backend_data.c b/src/backend/distributed/transaction/backend_data.c index 6efe81e6f..26d853507 100644 --- a/src/backend/distributed/transaction/backend_data.c +++ b/src/backend/distributed/transaction/backend_data.c @@ -371,7 +371,7 @@ StoreAllActiveTransactions(Tuplestorestate *tupleStore, TupleDesc tupleDescripto memset(values, 0, sizeof(values)); memset(isNulls, false, sizeof(isNulls)); - if (is_member_of_role(userId, DEFAULT_ROLE_MONITOR)) + if (is_member_of_role(userId, ROLE_PG_MONITOR)) { showAllTransactions = true; } diff --git a/src/include/distributed/version_compat.h b/src/include/distributed/version_compat.h index b2d3425b5..5bea3c427 100644 --- a/src/include/distributed/version_compat.h +++ b/src/include/distributed/version_compat.h @@ -33,9 +33,11 @@ #if PG_VERSION_NUM >= PG_VERSION_14 #define AlterTableStmtObjType(a) ((a)->objtype) #define F_NEXTVAL_COMPAT F_NEXTVAL +#define ROLE_MONITOR_COMPAT ROLE_PG_MONITOR #else #define AlterTableStmtObjType(a) ((a)->relkind) #define F_NEXTVAL_COMPAT F_NEXTVAL_OID +#define ROLE_MONITOR_COMPAT DEFAULT_ROLE_MONITOR #endif #if PG_VERSION_NUM >= PG_VERSION_13