5 column additions in test

flow/e2e/bigquery/peer_flow_bq_test.go

@@ -771,31 +771,9 @@ func (s PeerFlowE2ETestSuiteBQ) Test_All_Types_Schema_Changes_BQ() {
 	e2e.EnvNoError(s.t, env, err)
 	s.t.Log("Inserted rows of various types from c2 to c6 in the source table")
 
-	e2e.EnvWaitForEqualTables(env, s, "normalize altered row", tableName,
+	e2e.EnvWaitForEqualTables(env, s, "normalize altered row c2 to c6", tableName,
 		"id,c1,c2,c3,c4,c5,c6")
 
-	_, err = s.Conn().Exec(context.Background(), fmt.Sprintf(`
-		ALTER TABLE %s
-		ADD COLUMN c7 BOOL[],
-		ADD COLUMN c8 NUMERIC,
-		ADD COLUMN c9 JSON,
-		ADD COLUMN c10 TEXT
-		`,
-		srcTableName))
-
-	_, err = s.Conn().Exec(context.Background(), fmt.Sprintf(`
-		INSERT INTO %s(c7,c8,c9,c10) VALUES (
-		'{true, false}',
-		1.23,
-		'{"temperature":-8.02139037433155}',
-		'hello'
-		)`, srcTableName))
-
-	e2e.EnvNoError(s.t, env, err)
-
-	e2e.EnvWaitForEqualTables(env, s, "normalize altered row", tableName,
-		"id,c7,c8,c9,c10")
-
 	env.Cancel()
 	e2e.RequireEnvCanceled(s.t, env)
 }