diff --git a/src/spock_apply_heap.c b/src/spock_apply_heap.c index cdc917ca..2fd28e4c 100644 --- a/src/spock_apply_heap.c +++ b/src/spock_apply_heap.c @@ -1203,6 +1203,7 @@ spock_apply_heap_delete(SpockRelation *rel, SpockTupleData *oldtup) remotetuple, NULL, SpockResolution_Skip, InvalidTransactionId, false, InvalidRepOriginId, (TimestampTz) 0, edata->targetRel->idxoid); + heap_freetuple(remotetuple); } /* Cleanup. */ diff --git a/src/spock_worker.c b/src/spock_worker.c index 3cad4948..b3058fdc 100644 --- a/src/spock_worker.c +++ b/src/spock_worker.c @@ -427,7 +427,7 @@ spock_worker_detach(bool crash) LWLockAcquire(SpockCtx->lock, LW_EXCLUSIVE); - Assert(MySpockWorker->proc = MyProc); + Assert(MySpockWorker->proc == MyProc); Assert(MySpockWorker->generation == MySpockWorkerGeneration); MySpockWorker->proc = NULL;