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