diff --git a/src/dbnode/persist/fs/streaming_write_test.go b/src/dbnode/persist/fs/streaming_write_test.go index 06a8ce1fc7..6482f2a2d2 100644 --- a/src/dbnode/persist/fs/streaming_write_test.go +++ b/src/dbnode/persist/fs/streaming_write_test.go @@ -174,7 +174,7 @@ func TestReadStreamingWriteEmptyFileset(t *testing.T) { filePathPrefix := filepath.Join(dir, "") defer os.RemoveAll(dir) - w := newTestStreamingWriter(t, filePathPrefix, 0, testWriterStart, 0, 0) + w := newTestStreamingWriter(t, filePathPrefix, 0, testWriterStart, 0, 1) err := streamingWriteTestData(t, w, testWriterStart, nil) require.NoError(t, err) err = w.Close() @@ -208,7 +208,7 @@ func TestStreamingWriterAbort(t *testing.T) { filePathPrefix := filepath.Join(dir, "") defer os.RemoveAll(dir) - w := newTestStreamingWriter(t, filePathPrefix, 0, testWriterStart, 0, 0) + w := newTestStreamingWriter(t, filePathPrefix, 0, testWriterStart, 0, 1) err := streamingWriteTestData(t, w, testWriterStart, nil) require.NoError(t, err) err = w.Abort()