fix #2: Row filtering for logical replication

timbira · Aug 23, 2019 · ef7015a · ef7015a
1 parent b912243
commit ef7015a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/backend/replication/pgoutput/pgoutput.c b/src/backend/replication/pgoutput/pgoutput.c
@@ -31,6 +31,7 @@
 #include "utils/builtins.h"
 #include "utils/inval.h"
 #include "utils/int8.h"
+#include "utils/lsyscache.h"
 #include "utils/memutils.h"
 #include "utils/syscache.h"
 #include "utils/varlena.h"
@@ -430,8 +431,7 @@ pgoutput_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn,
 		/* prepare context per tuple */
 		ecxt = GetPerTupleExprContext(estate);
 		oldcxt = MemoryContextSwitchTo(estate->es_query_cxt);
-		ecxt->ecxt_scantuple = ExecInitExtraTupleSlot(estate);
-		ExecSetSlotDescriptor(ecxt->ecxt_scantuple, tupdesc);
+		ecxt->ecxt_scantuple = ExecInitExtraTupleSlot(estate, tupdesc);
 
 		ExecStoreTuple(new_tuple ? new_tuple : old_tuple, ecxt->ecxt_scantuple, InvalidBuffer, false);