diff --git a/src/backend/replication/logical/reorderbuffer.c b/src/backend/replication/logical/reorderbuffer.c
index b0ab91c..76ecfc0 100644
--- a/src/backend/replication/logical/reorderbuffer.c
+++ b/src/backend/replication/logical/reorderbuffer.c
@@ -2183,7 +2183,7 @@ ReorderBufferProcessTXN(ReorderBuffer *rb, ReorderBufferTXN *txn,
 						 * they're not required anymore. The creator of the
 						 * tuple tells us.
 						 */
-						if (change->data.tp.clear_toast_afterwards)
+						if (change->data.tp.clear_toast_afterwards || streaming)
 							ReorderBufferToastReset(rb, txn);
 					}
 					/* we're not interested in toast deletions */