diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
index d869b22153..43a11a2e72 100644
--- a/flow/connectors/postgres/postgres.go
+++ b/flow/connectors/postgres/postgres.go
@@ -468,7 +468,6 @@ func (c *PostgresConnector) NormalizeRecords(req *model.NormalizeRecordsRequest)
 		}
 		normalizeStatements := c.generateNormalizeStatements(destinationTableName, unchangedToastColsMap[destinationTableName],
 			rawTableIdentifier, supportsMerge, &peerdbCols)
-		fmt.Println(normalizeStatements)
 		for _, normalizeStatement := range normalizeStatements {
 			mergeStatementsBatch.Queue(normalizeStatement, batchIDs.NormalizeBatchID, batchIDs.SyncBatchID, destinationTableName).Exec(
 				func(ct pgconn.CommandTag) error {
diff --git a/flow/e2e/test_utils.go b/flow/e2e/test_utils.go
index cc3c7049d7..dc7e83d1c3 100644
--- a/flow/e2e/test_utils.go
+++ b/flow/e2e/test_utils.go
@@ -76,7 +76,7 @@ func SetupCDCFlowStatusQuery(env *testsuite.TestWorkflowEnvironment,
 				slog.Error(err.Error())
 			}
 
-			if state.CurrentFlowState == protos.FlowStatus_STATUS_RUNNING.Enum() {
+			if *state.CurrentFlowState == protos.FlowStatus_STATUS_RUNNING {
 				break
 			}
 		} else {