We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 568e782 commit ceeb65fCopy full SHA for ceeb65f
index/scorch/merge.go
@@ -226,12 +226,14 @@ func (s *Scorch) parseMergePlannerOptions() (*mergeplan.MergePlanOptions,
226
}
227
228
229
- po, err := s.parsePersisterOptions()
230
- if err != nil {
231
- return nil, err
232
- }
+ if mergePlannerOptions.FloorSegmentFileSize == 0 {
+ po, err := s.parsePersisterOptions()
+ if err != nil {
+ return nil, err
233
+ }
234
- mergePlannerOptions.FloorSegmentFileSize = int64(po.MaxSizeInMemoryMergePerWorker)
235
+ mergePlannerOptions.FloorSegmentFileSize = int64(po.MaxSizeInMemoryMergePerWorker)
236
237
238
return &mergePlannerOptions, nil
239
0 commit comments