external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Call relation access hash clean-up irrespective of remote transaction state 

Mainly because local-only transactions should be cleaned up
pull/6092/head
Onder Kalaci 2022-07-27 18:06:53 +02:00
parent d67cf907a2
commit 0a5112964d
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/backend/distributed/connection/placement_connection.c
View File

@ -969,7 +969,6 @@ ResetPlacementConnectionManagement(void)
hash_delete_all(ConnectionPlacementHash); hash_delete_all(ConnectionPlacementHash);
hash_delete_all(ConnectionShardHash); hash_delete_all(ConnectionShardHash);
hash_delete_all(ColocatedPlacementsHash); hash_delete_all(ColocatedPlacementsHash);
ResetRelationAccessHash();
/* /*
* NB: memory for ConnectionReference structs and subordinate data is * NB: memory for ConnectionReference structs and subordinate data is

3
src/backend/distributed/transaction/transaction_management.c
View File

@ -36,6 +36,7 @@
#include "distributed/repartition_join_execution.h" #include "distributed/repartition_join_execution.h"
#include "distributed/transaction_management.h" #include "distributed/transaction_management.h"
#include "distributed/placement_connection.h" #include "distributed/placement_connection.h"
#include "distributed/relation_access_tracking.h"
#include "distributed/shared_connection_stats.h" #include "distributed/shared_connection_stats.h"
#include "distributed/subplan_execution.h" #include "distributed/subplan_execution.h"
#include "distributed/version_compat.h" #include "distributed/version_compat.h"
@ -307,6 +308,7 @@ CoordinatedTransactionCallback(XactEvent event, void *arg)
} }
ResetGlobalVariables(); ResetGlobalVariables();
ResetRelationAccessHash();
/* /*
* Make sure that we give the shared connections back to the shared * Make sure that we give the shared connections back to the shared
@ -376,6 +378,7 @@ CoordinatedTransactionCallback(XactEvent event, void *arg)
AfterXactConnectionHandling(false); AfterXactConnectionHandling(false);
ResetGlobalVariables(); ResetGlobalVariables();
ResetRelationAccessHash();
/* /*
* Clear MetadataCache table if we're aborting from a CREATE EXTENSION Citus * Clear MetadataCache table if we're aborting from a CREATE EXTENSION Citus