File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -305,7 +305,7 @@ func TestAlterChangefeedAddTargetAfterInitialScan(t *testing.T) {
305
305
t .Fatalf ("unknown initial scan type %q" , initialScan )
306
306
}
307
307
308
- sqlDB .QueryRow (t , `INSERT INTO foo VALUES(2)` )
308
+ sqlDB .Exec (t , `INSERT INTO foo VALUES(2)` )
309
309
assertPayloads (t , testFeed , []string {
310
310
`foo: [2]->{"after": {"a": 2}}` ,
311
311
})
@@ -1915,7 +1915,7 @@ func TestAlterChangefeedAddDropSameTarget(t *testing.T) {
1915
1915
sqlDB .Exec (t , fmt .Sprintf (`ALTER CHANGEFEED %d ADD bar DROP bar` , feed .JobID ()))
1916
1916
require .NoError (t , feed .Resume ())
1917
1917
var tsStr string
1918
- sqlDB .QueryRow (t , `INSERT INTO bar VALUES(1)` )
1918
+ sqlDB .Exec (t , `INSERT INTO bar VALUES(1)` )
1919
1919
sqlDB .QueryRow (t , `INSERT INTO foo VALUES(2) RETURNING cluster_logical_timestamp()` ).Scan (& tsStr )
1920
1920
ts := parseTimeToHLC (t , tsStr )
1921
1921
require .NoError (t , feed .WaitForHighWaterMark (ts ))
You can’t perform that action at this time.
0 commit comments