diff --git a/internal/datacoord/meta.go b/internal/datacoord/meta.go index 4b95011272..29070d7388 100644 --- a/internal/datacoord/meta.go +++ b/internal/datacoord/meta.go @@ -1041,6 +1041,7 @@ func (m *meta) PrepareCompleteCompactionMutation(plan *datapb.CompactionPlan, CreatedByCompaction: true, CompactionFrom: compactionFrom, LastExpireTime: plan.GetStartTime(), + Level: datapb.SegmentLevel_L1, } segment := NewSegmentInfo(segmentInfo) metricMutation.addNewSeg(segment.GetState(), segment.GetLevel(), segment.GetNumOfRows()) @@ -1048,6 +1049,7 @@ func (m *meta) PrepareCompleteCompactionMutation(plan *datapb.CompactionPlan, zap.Int64("collectionID", segment.GetCollectionID()), zap.Int64("partitionID", segment.GetPartitionID()), zap.Int64("new segment ID", segment.GetID()), + zap.String("new segment level", segment.GetLevel().String()), zap.Int64("new segment num of rows", segment.GetNumOfRows()), zap.Any("compacted from", segment.GetCompactionFrom())) diff --git a/internal/datacoord/meta_test.go b/internal/datacoord/meta_test.go index da385608da..7d8ab5bb45 100644 --- a/internal/datacoord/meta_test.go +++ b/internal/datacoord/meta_test.go @@ -730,7 +730,8 @@ func TestMeta_PrepareCompleteCompactionMutation(t *testing.T) { assert.NoError(t, err) assert.NotNil(t, afterCompact) assert.NotNil(t, newSegment) - assert.Equal(t, 3, len(metricMutation.stateChange[datapb.SegmentLevel_Legacy.String()])) + assert.Equal(t, 2, len(metricMutation.stateChange[datapb.SegmentLevel_Legacy.String()])) + assert.Equal(t, 1, len(metricMutation.stateChange[datapb.SegmentLevel_L1.String()])) assert.Equal(t, int64(0), metricMutation.rowCountChange) assert.Equal(t, int64(2), metricMutation.rowCountAccChange)