structured log for beginning of compaction
This commit is contained in:
parent
e52c709d8a
commit
09cd1175a1
@ -352,8 +352,7 @@ func (s *SplitStore) compactSimple() {
|
|||||||
|
|
||||||
coldEpoch := s.baseEpoch + CompactionCold
|
coldEpoch := s.baseEpoch + CompactionCold
|
||||||
|
|
||||||
log.Infof("running simple compaction; currentEpoch: %d baseEpoch: %d coldEpoch: %d",
|
log.Infow("running simple compaction", "currentEpoch", curTs.Height(), "baseEpoch", s.baseEpoch, "coldEpoch", coldEpoch)
|
||||||
curTs.Height(), s.baseEpoch, coldEpoch)
|
|
||||||
|
|
||||||
coldSet, err := s.env.NewLiveSet("cold")
|
coldSet, err := s.env.NewLiveSet("cold")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -499,8 +498,7 @@ func (s *SplitStore) compactFull() {
|
|||||||
epoch := curTs.Height()
|
epoch := curTs.Height()
|
||||||
coldEpoch := s.baseEpoch + CompactionCold
|
coldEpoch := s.baseEpoch + CompactionCold
|
||||||
|
|
||||||
log.Infof("running full compaction; currentEpoch: %d baseEpoch: %d coldEpoch: %d",
|
log.Infow("running full compaction", "currentEpoch", curTs.Height(), "baseEpoch", s.baseEpoch, "coldEpoch", coldEpoch)
|
||||||
curTs.Height(), s.baseEpoch, coldEpoch)
|
|
||||||
|
|
||||||
// create two live sets, one for marking the cold finality region
|
// create two live sets, one for marking the cold finality region
|
||||||
// and one for marking the hot region
|
// and one for marking the hot region
|
||||||
|
Loading…
Reference in New Issue
Block a user