diff --git a/internal/datacoord/server_test.go b/internal/datacoord/server_test.go index 95f9d6899d..d4314bed59 100644 --- a/internal/datacoord/server_test.go +++ b/internal/datacoord/server_test.go @@ -1254,6 +1254,23 @@ func TestGetRecoveryInfo(t *testing.T) { }, }, }, + Field2StatslogPaths: []*datapb.FieldBinlog{ + { + FieldID: 1, + Binlogs: []string{ + "/stats_log/file1", + "/stats_log/file2", + }, + }, + }, + Deltalogs: []*datapb.DeltaLogInfo{ + { + TimestampFrom: 0, + TimestampTo: 1, + DeltaLogPath: "/stats_log/file1", + DeltaLogSize: 1, + }, + }, } segment := createSegment(0, 0, 0, 100, 10, "ch1", commonpb.SegmentState_Flushed) err := svr.meta.AddSegment(NewSegmentInfo(segment)) diff --git a/internal/datanode/segment_replica_test.go b/internal/datanode/segment_replica_test.go index cae7a7c7e5..86a919bb27 100644 --- a/internal/datanode/segment_replica_test.go +++ b/internal/datanode/segment_replica_test.go @@ -91,7 +91,7 @@ func (kv *mockMinioKVStatsError) MultiLoad(keys []string) ([]string, error) { func getSimpleFieldBinlog() *datapb.FieldBinlog { return &datapb.FieldBinlog{ - FieldID: 100, + FieldID: 106, Binlogs: []string{"test"}, } }