We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 108e185 commit 9ac16d0Copy full SHA for 9ac16d0
wal.go
@@ -344,6 +344,7 @@ func (wal *WAL) rotateActiveSegment() error {
344
}
345
346
// WriteAll write wal.pendingWrites to WAL and then clear pendingWrites
347
+// WriteAll will Not sync segment based on wal.options
348
func (wal *WAL) WriteAll() ([]*ChunkPosition, error) {
349
if len(wal.pendingWrites) == 0 {
350
return make([]*ChunkPosition, 0), nil
@@ -368,11 +369,6 @@ func (wal *WAL) WriteAll() ([]*ChunkPosition, error) {
368
369
return nil, err
370
371
- // sync the active segment file to ensure the durability.
372
- if err := wal.activeSegment.Sync(); err != nil {
373
- return nil, err
374
- }
375
-
376
return positions, nil
377
378
0 commit comments