Skip to content

Commit bf47b3c

Browse files
committed
Fixed previous partial commit
1 parent 50b212c commit bf47b3c

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pglogical_apply.c

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -466,6 +466,8 @@ handle_insert(StringInfo s)
466466

467467
ExecCloseIndices(estate->es_result_relation_info);
468468

469+
PopActiveSnapshot();
470+
469471
/* if INSERT was into our queue, process the message. */
470472
if (RelationGetRelid(rel->rel) == QueueRelid)
471473
{

0 commit comments

Comments
 (0)