|
|
|
@ -573,9 +573,12 @@ func Test_SingleNodeQueryTimeout(t *testing.T) {
|
|
|
|
|
q := `SELECT key1, key_id, key2, key3, key4, key5, key6, data
|
|
|
|
|
FROM test_table
|
|
|
|
|
ORDER BY key2 ASC`
|
|
|
|
|
_, err = node.QueryWithTimeout(q, 1*time.Microsecond)
|
|
|
|
|
if err == nil {
|
|
|
|
|
t.Fatalf("query succeeded when it should have timed out")
|
|
|
|
|
r, err = node.QueryWithTimeout(q, 1*time.Microsecond)
|
|
|
|
|
if err != nil {
|
|
|
|
|
t.Fatalf("failed to query with timeout: %s", err.Error())
|
|
|
|
|
}
|
|
|
|
|
if exp, got := `{"results":[{"error":"context deadline exceeded"}]}`, r; exp != got {
|
|
|
|
|
t.Fatalf("test received wrong result\nexp: %s\ngot: %s\n", exp, got)
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|