diff --git a/go/vt/vtgate/executor_test.go b/go/vt/vtgate/executor_test.go index f018d8e840e..f28e7276caa 100644 --- a/go/vt/vtgate/executor_test.go +++ b/go/vt/vtgate/executor_test.go @@ -1883,7 +1883,6 @@ func TestExecutorMaxPayloadSizeExceeded(t *testing.T) { session := NewSafeSession(&vtgatepb.Session{TargetString: "@master"}) warningCount := warnings.Counts()["WarnPayloadSizeExceeded"] testMaxPayloadSizeExceeded := []string{ - "select * from main1", "select * from main1", "insert into main1(id) values (1), (2)", "update main1 set id=1", @@ -1891,9 +1890,8 @@ func TestExecutorMaxPayloadSizeExceeded(t *testing.T) { } for _, query := range testMaxPayloadSizeExceeded { _, err := executor.Execute(context.Background(), "TestExecutorMaxPayloadSizeExceeded", session, query, nil) - if err == nil { - assert.EqualError(t, err, "query payload size above threshold") - } + require.NotNil(t, err) + assert.EqualError(t, err, "query payload size above threshold") } assert.Equal(t, warningCount, warnings.Counts()["WarnPayloadSizeExceeded"], "warnings count")