diff --git a/src/backend/distributed/shardsplit/shardsplit_decoder.c b/src/backend/distributed/shardsplit/shardsplit_decoder.c index 1386a21b0..eee0ce6b3 100644 --- a/src/backend/distributed/shardsplit/shardsplit_decoder.c +++ b/src/backend/distributed/shardsplit/shardsplit_decoder.c @@ -170,6 +170,7 @@ shard_split_change_cb(LogicalDecodingContext *ctx, ReorderBufferTXN *txn, /* Current replication slot is not responsible for handling the change */ if (targetRelationOid == InvalidOid) { + pgOutputPluginChangeCB(ctx, txn, relation, change); return; }