Log WARNING when no delta tuple found
@@ -1484,6 +1484,8 @@ sync_combine(ContQueryCombinerState *state)
{
HeapTupleEntry e = (HeapTupleEntry) LookupTupleHashEntry(state->deltas, slot, NULL);
+ if (e != NULL)
+ {
os_values[DELTA_TUPLE] = heap_copy_tuple_as_datum(e->tuple, state->desc);
os_nulls[DELTA_TUPLE] = false;
@@ -1492,6 +1494,11 @@ sync_combine(ContQueryCombinerState *state)
ExecStoreTuple(os_tup, state->os_slot, InvalidBuffer, false);
ExecStreamInsert(NULL, osri, state->os_slot, NULL);
}
+ else
+ {
+ elog(WARNING, "tuple not found in delta store");
+ }
+ }
ResetPerTupleExprContext(estate);
}
