mirror of https://github.com/citusdata/citus.git
Merge pull request #2997 from citusdata/fix_master_update_node
Set current snapshot in maintenance daemon.pull/3001/head
commit
4875c3c81c
|
@ -375,6 +375,12 @@ CitusMaintenanceDaemonMain(Datum main_arg)
|
||||||
InvalidateMetadataSystemCache();
|
InvalidateMetadataSystemCache();
|
||||||
StartTransactionCommand();
|
StartTransactionCommand();
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Some functions in ruleutils.c, which we use to get the DDL for
|
||||||
|
* metadata propagation, require an active snapshot.
|
||||||
|
*/
|
||||||
|
PushActiveSnapshot(GetTransactionSnapshot());
|
||||||
|
|
||||||
if (!LockCitusExtension())
|
if (!LockCitusExtension())
|
||||||
{
|
{
|
||||||
ereport(DEBUG1, (errmsg("could not lock the citus extension, "
|
ereport(DEBUG1, (errmsg("could not lock the citus extension, "
|
||||||
|
@ -386,6 +392,7 @@ CitusMaintenanceDaemonMain(Datum main_arg)
|
||||||
Async_Notify(METADATA_SYNC_CHANNEL, NULL);
|
Async_Notify(METADATA_SYNC_CHANNEL, NULL);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
PopActiveSnapshot();
|
||||||
CommitTransactionCommand();
|
CommitTransactionCommand();
|
||||||
ProcessCompletedNotifies();
|
ProcessCompletedNotifies();
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue