From dbfe1fbbd5a101c081bdc8af37dc70d16917c98c Mon Sep 17 00:00:00 2001 From: Naci Ishakbeyoglu Date: Thu, 4 May 2017 23:29:18 -0700 Subject: [PATCH] DBZ-223 Handles dropped columns correctly. --- src/decoderbufs.c | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/decoderbufs.c b/src/decoderbufs.c index 8669c1e..585cb5d 100644 --- a/src/decoderbufs.c +++ b/src/decoderbufs.c @@ -563,6 +563,7 @@ static void tuple_to_tuple_msg(Decoderbufs__DatumMessage **tmsg, Relation relation, HeapTuple tuple, TupleDesc tupdesc) { int natt; + int valid_attr_cnt = 0; elog(DEBUG1, "processing tuple with %d columns", tupdesc->natts); /* build column names and values */ for (natt = 0; natt < tupdesc->natts; natt++) { @@ -611,8 +612,10 @@ static void tuple_to_tuple_msg(Decoderbufs__DatumMessage **tmsg, elog(DEBUG1, "column %s is null, ignoring value", attrName); } - tmsg[natt] = palloc(sizeof(datum_msg)); - memcpy(tmsg[natt], &datum_msg, sizeof(datum_msg)); + tmsg[valid_attr_cnt] = palloc(sizeof(datum_msg)); + memcpy(tmsg[valid_attr_cnt], &datum_msg, sizeof(datum_msg)); + + valid_attr_cnt++; } }