From 19b67de8f4eaffb4cbe8bc78a9998858af6bec9c Mon Sep 17 00:00:00 2001 From: EmelSimsek Date: Tue, 12 Sep 2023 02:22:41 +0300 Subject: [PATCH] Attempt to fix stalls --- src/backend/distributed/shardsplit/shardsplit_decoder.c | 1 + 1 file changed, 1 insertion(+) 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; }