> I think if the GUC is set then maybe we can bypass this check so that > it can try to stream every single change? >
Yeah and probably we need to do something for the check "while (rb->size >= logical_decoding_work_mem * 1024L)" as well.
I have made this change, as discussed, the regression tests seem to run fine. I have added a debug that records the streaming for each transaction number. I also had to bypass certain asserts in ReorderBufferLargestTopTXN() as now we are going through the entire list of transactions and not just picking the biggest transaction .
