index 23ab3cf60524687459206862a2daaf50ed704b9b..afa1df00d0eafcfb44183ed308d083cdef27c2e1 100644 (file)
@@ -685,10 +685,10 @@ DecodeCommit(LogicalDecodingContext *ctx, XLogRecordBuffer *buf,
* so during startup, to get to the first transaction the client needs. As
* we have reset the catalog caches before starting to read WAL, and we
* haven't yet touched any catalogs, there can't be anything to invalidate.
- * But if we're "forgetting" this commit because it's it happened in
- * another database, the invalidations might be important, because they
- * could be for shared catalogs and we might have loaded data into the
- * relevant syscaches.
+ * But if we're "forgetting" this commit because it happened in another
+ * database, the invalidations might be important, because they could be
+ * for shared catalogs and we might have loaded data into the relevant
+ * syscaches.
* ---
*/
if (DecodeTXNNeedSkip(ctx, buf, parsed->dbId, origin_id))
index 605ec0986caa311e625007eac9b82e532f123403..0977aec711cff529320f1e73285b2a3f02c2a80f 100644 (file)
@@ -1371,7 +1371,7 @@ stream_commit_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn,
ctx->write_xid = txn->xid;
ctx->write_location = txn->end_lsn;
- /* in streaming mode, stream_abort_cb is required */
+ /* in streaming mode, stream_commit_cb is required */
if (ctx->callbacks.stream_commit_cb == NULL)
ereport(ERROR,
(errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),