Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

feat: Fix up some tests that I forgot to adjust

db/4201/compaction-bugs
Devan 2024-12-18 14:34:55 -06:00
parent 403d888020
commit 23d12e1046
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tsdb/engine/tsm1/compact_test.go
View File

@ -2501,9 +2501,9 @@ func TestDefaultPlanner_FullyCompacted_SmallSingleGeneration(t *testing.T) {
require.Equal(t, int64(0), cgLen, "compaction group length; Plan()")
cgroup, cgLen, genLen := cp.PlanOptimize()
require.Equal(t, []tsm1.CompactionGroup(nil), cgroup, "compaction group")
require.Equal(t, int64(0), cgLen, "compaction group length")
require.Equal(t, int64(0), genLen, "generation count")
require.Equal(t, len(data), cgroup, "compaction group")
require.Equal(t, int64(4), cgLen, "compaction group length")
require.Equal(t, int64(1), genLen, "generation count")
}
// This test is added to account for halting state after
@ -2621,10 +2621,9 @@ func TestDefaultPlanner_FullyCompacted_LargeSingleGenerationUnderAggressiveBlock
_, cgLen = cp.Plan(time.Now().Add(-1))
require.Equal(t, int64(0), cgLen, "compaction group length; Plan()")
cgroup, cgLen, genLen := cp.PlanOptimize()
require.Equal(t, []tsm1.CompactionGroup(nil), cgroup, "compaction group")
require.Equal(t, int64(0), cgLen, "compaction group length")
require.Equal(t, int64(0), genLen, "generation count")
_, cgLen, genLen := cp.PlanOptimize()
require.Equal(t, int64(8), cgLen, "compaction group length")
require.Equal(t, int64(1), genLen, "generation count")
}
// This test is added to account for a single generation that has a group size