From eb4024dd2d20c9c12bf99cb40c8258b6ecc93dae Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Sat, 21 Oct 2023 15:30:51 -0400 Subject: [PATCH] Revert "for eventhub disable commit lock (#546)" (#551) This reverts commit 41dfd4f024caa432feb7deef89659108ae421fe6. --- flow/connectors/postgres/cdc.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go index fe30d74c6b..9bfff285ae 100644 --- a/flow/connectors/postgres/cdc.go +++ b/flow/connectors/postgres/cdc.go @@ -317,11 +317,7 @@ func (p *PostgresCDCSource) processMessage(batch *model.RecordBatch, xld pglogre case *pglogrepl.BeginMessage: log.Debugf("BeginMessage => FinalLSN: %v, XID: %v", msg.FinalLSN, msg.Xid) log.Debugf("Locking PullRecords at BeginMessage, awaiting CommitMessage") - if utils.GetEnvBool("PEERDB_BETA_EVENTHUB_PUSH_ASYNC", false) { - p.commitLock = false - } else { - p.commitLock = true - } + p.commitLock = true case *pglogrepl.InsertMessage: return p.processInsertMessage(xld.WALStart, msg) case *pglogrepl.UpdateMessage: