fix tests by closing iterators and cursors
parent
7de2dcd3d9
commit
63b9c98187
|
@ -726,6 +726,7 @@ func TestEngine_CreateIterator_TSM_Ascending(t *testing.T) {
|
|||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer itr.Close()
|
||||
fitr := itr.(query.FloatIterator)
|
||||
|
||||
if p, err := fitr.Next(); err != nil {
|
||||
|
@ -783,6 +784,7 @@ func TestEngine_CreateIterator_TSM_Descending(t *testing.T) {
|
|||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer itr.Close()
|
||||
fitr := itr.(query.FloatIterator)
|
||||
|
||||
if p, err := fitr.Next(); err != nil {
|
||||
|
@ -1749,6 +1751,7 @@ func TestEngine_CreateCursor_Ascending(t *testing.T) {
|
|||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer cur.Close()
|
||||
|
||||
fcur := cur.(tsdb.FloatBatchCursor)
|
||||
ts, vs := fcur.Next()
|
||||
|
@ -1808,6 +1811,7 @@ func TestEngine_CreateCursor_Descending(t *testing.T) {
|
|||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
defer cur.Close()
|
||||
|
||||
fcur := cur.(tsdb.FloatBatchCursor)
|
||||
ts, vs := fcur.Next()
|
||||
|
|
Loading…
Reference in New Issue