diff --git a/flow/e2e/congen.go b/flow/e2e/congen.go
index 8599fcc1ab..c0d91e0460 100644
--- a/flow/e2e/congen.go
+++ b/flow/e2e/congen.go
@@ -173,17 +173,14 @@ func TableMappings(s GenericSuite, tables ...string) []*protos.TableMapping {
 	if len(tables)&1 != 0 {
 		panic("must receive even number of table names")
 	}
-	tableMappings := make([]*protos.TableMapping, len(tables)/2)
+	tm := make([]*protos.TableMapping, len(tables)/2)
 	for i := 0; i < len(tables); i += 2 {
-		tableMappings = append(
-			tableMappings,
-			&protos.TableMapping{
-				SourceTableIdentifier:      AttachSchema(s, tables[i]),
-				DestinationTableIdentifier: s.DestinationTable(tables[i+1]),
-			},
-		)
-	}
-	return tableMappings
+		tm = append(tm, &protos.TableMapping{
+			SourceTableIdentifier:      AttachSchema(s, tables[i]),
+			DestinationTableIdentifier: s.DestinationTable(tables[i+1]),
+		})
+	}
+	return tm
 }
 
 func (c *FlowConnectionGenerationConfig) GenerateFlowConnectionConfigs() *protos.FlowConnectionConfigs {
diff --git a/flow/e2e/postgres/peer_flow_pg_test.go b/flow/e2e/postgres/peer_flow_pg_test.go
index c56608c9f6..b1a6c4049e 100644
--- a/flow/e2e/postgres/peer_flow_pg_test.go
+++ b/flow/e2e/postgres/peer_flow_pg_test.go
@@ -98,6 +98,10 @@ func (s PeerFlowE2ETestSuitePG) Test_Simple_Flow_PG() {
 	}
 
 	flowConnConfig := connectionGen.GenerateFlowConnectionConfigs()
+	for _, tm := range flowConnConfig.TableMappings {
+		s.t.Log(tm.SourceTableIdentifier, tm.DestinationTableIdentifier)
+		s.t.Log(s.attachSchemaSuffix("test_simple_flow"), s.attachSchemaSuffix("test_simple_flow_dst"))
+	}
 	flowConnConfig.MaxBatchSize = 100
 
 	tc := e2e.NewTemporalClient(s.t)