@@ -509,16 +509,16 @@ func TestCompactor_ShouldIterateOverUsersAndRunCompaction(t *testing.T) {
509
509
`level=info component=compactor msg="discovering users from bucket"` ,
510
510
`level=info component=compactor msg="discovered users from bucket" users=2` ,
511
511
`level=info component=compactor msg="starting compaction of user blocks" user=user-1` ,
512
- `component=compactor org_id=user-1 level=info msg="start sync of metas"` ,
513
- `component=compactor org_id=user-1 level=info msg="start of GC"` ,
514
- `component=compactor org_id=user-1 level=info msg="start of compactions"` ,
515
- `component=compactor org_id=user-1 level=info msg="compaction iterations done"` ,
512
+ `level=info component=compactor org_id=user-1 msg="start sync of metas"` ,
513
+ `level=info component=compactor org_id=user-1 msg="start of GC"` ,
514
+ `level=info component=compactor org_id=user-1 msg="start of compactions"` ,
515
+ `level=info component=compactor org_id=user-1 msg="compaction iterations done"` ,
516
516
`level=info component=compactor msg="successfully compacted user blocks" user=user-1` ,
517
517
`level=info component=compactor msg="starting compaction of user blocks" user=user-2` ,
518
- `component=compactor org_id=user-2 level=info msg="start sync of metas"` ,
519
- `component=compactor org_id=user-2 level=info msg="start of GC"` ,
520
- `component=compactor org_id=user-2 level=info msg="start of compactions"` ,
521
- `component=compactor org_id=user-2 level=info msg="compaction iterations done"` ,
518
+ `level=info component=compactor org_id=user-2 msg="start sync of metas"` ,
519
+ `level=info component=compactor org_id=user-2 msg="start of GC"` ,
520
+ `level=info component=compactor org_id=user-2 msg="start of compactions"` ,
521
+ `level=info component=compactor org_id=user-2 msg="compaction iterations done"` ,
522
522
`level=info component=compactor msg="successfully compacted user blocks" user=user-2` ,
523
523
}, removeIgnoredLogs (strings .Split (strings .TrimSpace (logs .String ()), "\n " )))
524
524
@@ -625,18 +625,18 @@ func TestCompactor_ShouldNotCompactBlocksMarkedForDeletion(t *testing.T) {
625
625
assert .ElementsMatch (t , []string {
626
626
`level=info component=cleaner msg="started blocks cleanup and maintenance"` ,
627
627
`level=info component=cleaner org_id=user-1 msg="started blocks cleanup and maintenance"` ,
628
- `component=cleaner org_id=user-1 level=debug msg="deleted file" file=01DTW0ZCPDDNV4BV83Q2SV4QAZ/meta.json bucket=mock` ,
629
- `component=cleaner org_id=user-1 level=debug msg="deleted file" file=01DTW0ZCPDDNV4BV83Q2SV4QAZ/deletion-mark.json bucket=mock` ,
628
+ `level=debug component=cleaner org_id=user-1 msg="deleted file" file=01DTW0ZCPDDNV4BV83Q2SV4QAZ/meta.json bucket=mock` ,
629
+ `level=debug component=cleaner org_id=user-1 msg="deleted file" file=01DTW0ZCPDDNV4BV83Q2SV4QAZ/deletion-mark.json bucket=mock` ,
630
630
`level=info component=cleaner org_id=user-1 msg="deleted block marked for deletion" block=01DTW0ZCPDDNV4BV83Q2SV4QAZ` ,
631
631
`level=info component=cleaner org_id=user-1 msg="completed blocks cleanup and maintenance"` ,
632
632
`level=info component=cleaner msg="successfully completed blocks cleanup and maintenance"` ,
633
633
`level=info component=compactor msg="discovering users from bucket"` ,
634
634
`level=info component=compactor msg="discovered users from bucket" users=1` ,
635
635
`level=info component=compactor msg="starting compaction of user blocks" user=user-1` ,
636
- `component=compactor org_id=user-1 level=info msg="start sync of metas"` ,
637
- `component=compactor org_id=user-1 level=info msg="start of GC"` ,
638
- `component=compactor org_id=user-1 level=info msg="start of compactions"` ,
639
- `component=compactor org_id=user-1 level=info msg="compaction iterations done"` ,
636
+ `level=info component=compactor org_id=user-1 msg="start sync of metas"` ,
637
+ `level=info component=compactor org_id=user-1 msg="start of GC"` ,
638
+ `level=info component=compactor org_id=user-1 msg="start of compactions"` ,
639
+ `level=info component=compactor org_id=user-1 msg="compaction iterations done"` ,
640
640
`level=info component=compactor msg="successfully compacted user blocks" user=user-1` ,
641
641
}, removeIgnoredLogs (strings .Split (strings .TrimSpace (logs .String ()), "\n " )))
642
642
@@ -733,8 +733,8 @@ func TestCompactor_ShouldNotCompactBlocksForUsersMarkedForDeletion(t *testing.T)
733
733
assert .ElementsMatch (t , []string {
734
734
`level=info component=cleaner msg="started blocks cleanup and maintenance"` ,
735
735
`level=info component=cleaner org_id=user-1 msg="deleting blocks for tenant marked for deletion"` ,
736
- `component=cleaner org_id=user-1 level=debug msg="deleted file" file=01DTVP434PA9VFXSW2JKB3392D/meta.json bucket=mock` ,
737
- `component=cleaner org_id=user-1 level=debug msg="deleted file" file=01DTVP434PA9VFXSW2JKB3392D/index bucket=mock` ,
736
+ `level=debug component=cleaner org_id=user-1 msg="deleted file" file=01DTVP434PA9VFXSW2JKB3392D/meta.json bucket=mock` ,
737
+ `level=debug component=cleaner org_id=user-1 msg="deleted file" file=01DTVP434PA9VFXSW2JKB3392D/index bucket=mock` ,
738
738
`level=info component=cleaner org_id=user-1 msg="deleted block" block=01DTVP434PA9VFXSW2JKB3392D` ,
739
739
`level=info component=cleaner org_id=user-1 msg="deleted blocks for tenant marked for deletion" deletedBlocks=1` ,
740
740
`level=info component=cleaner org_id=user-1 msg="updating finished time in tenant deletion mark"` ,
@@ -854,16 +854,16 @@ func TestCompactor_ShouldCompactAllUsersOnShardingEnabledButOnlyOneInstanceRunni
854
854
`level=info component=compactor msg="discovering users from bucket"` ,
855
855
`level=info component=compactor msg="discovered users from bucket" users=2` ,
856
856
`level=info component=compactor msg="starting compaction of user blocks" user=user-1` ,
857
- `component=compactor org_id=user-1 level=info msg="start sync of metas"` ,
858
- `component=compactor org_id=user-1 level=info msg="start of GC"` ,
859
- `component=compactor org_id=user-1 level=info msg="start of compactions"` ,
860
- `component=compactor org_id=user-1 level=info msg="compaction iterations done"` ,
857
+ `level=info component=compactor org_id=user-1 msg="start sync of metas"` ,
858
+ `level=info component=compactor org_id=user-1 msg="start of GC"` ,
859
+ `level=info component=compactor org_id=user-1 msg="start of compactions"` ,
860
+ `level=info component=compactor org_id=user-1 msg="compaction iterations done"` ,
861
861
`level=info component=compactor msg="successfully compacted user blocks" user=user-1` ,
862
862
`level=info component=compactor msg="starting compaction of user blocks" user=user-2` ,
863
- `component=compactor org_id=user-2 level=info msg="start sync of metas"` ,
864
- `component=compactor org_id=user-2 level=info msg="start of GC"` ,
865
- `component=compactor org_id=user-2 level=info msg="start of compactions"` ,
866
- `component=compactor org_id=user-2 level=info msg="compaction iterations done"` ,
863
+ `level=info component=compactor org_id=user-2 msg="start sync of metas"` ,
864
+ `level=info component=compactor org_id=user-2 msg="start of GC"` ,
865
+ `level=info component=compactor org_id=user-2 msg="start of compactions"` ,
866
+ `level=info component=compactor org_id=user-2 msg="compaction iterations done"` ,
867
867
`level=info component=compactor msg="successfully compacted user blocks" user=user-2` ,
868
868
}, removeIgnoredLogs (strings .Split (strings .TrimSpace (logs .String ()), "\n " )))
869
869
}
0 commit comments