Skip to content

Commit 9bc4cd2

Browse files
committed
lint
1 parent e398188 commit 9bc4cd2

1 file changed

Lines changed: 13 additions & 7 deletions

File tree

pkg/ingestor/globalsort/split_test.go

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -456,7 +456,7 @@ func Test3KFilesRangeSplitter(t *testing.T) {
456456
key[keySize-1] = byte(i % 256)
457457
key[keySize-2] = byte(i / 256)
458458
// to make sure the encoded KV size is 20KB
459-
value := make([]byte, size.KB - 2 * simplesst.LengthBytes)
459+
value := make([]byte, size.KB-2*simplesst.LengthBytes)
460460
minKey := slices.Clone(key)
461461
var maxKey []byte
462462

@@ -465,18 +465,22 @@ func Test3KFilesRangeSplitter(t *testing.T) {
465465
statFile := filepath.Join(uuid.New().String(), "one-file")
466466
statWriter, err := store.Create(ctx, statFile, &storeapi.WriterOption{
467467
Concurrency: 8,
468-
PartSize: 5*units.MiB,
468+
PartSize: 5 * units.MiB,
469469
})
470-
require.NoError(t, err)
470+
if err != nil {
471+
return err
472+
}
471473

472-
memSize, lastMemSize := uint64(0), uint64(0)
474+
memSize, lastMemSize := uint64(0), uint64(0)
473475
for j := range int(64 * size.GB / kvSize) {
474476
if memSize-lastMemSize >= simplesst.DefaultMemSizeLimit {
475-
lastMemSize=memSize
477+
lastMemSize = memSize
476478
kvStore.Finish()
477479
encodedStat := rc.Encode()
478480
_, err := statWriter.Write(ctx, encodedStat)
479-
require.NoError(t, err)
481+
if err != nil {
482+
return err
483+
}
480484
rc.Reset()
481485
// the new prop should have the same offset with kvStore.
482486
rc.CurrProp().Offset = memSize
@@ -501,7 +505,9 @@ func Test3KFilesRangeSplitter(t *testing.T) {
501505
kvStore.Finish()
502506
encodedStat := rc.Encode()
503507
_, err = statWriter.Write(ctx, encodedStat)
504-
require.NoError(t, err)
508+
if err != nil {
509+
return err
510+
}
505511

506512
// copied from mergeOverlappingFilesInternal
507513
var stat simplesst.MultipleFilesStat

0 commit comments

Comments
 (0)