diff options
| author | chrislusf <chris.lu@gmail.com> | 2015-05-08 23:43:59 -0700 |
|---|---|---|
| committer | chrislusf <chris.lu@gmail.com> | 2015-05-08 23:43:59 -0700 |
| commit | 66317b843838f9eb63230d0916d525f75b8b30e2 (patch) | |
| tree | ad3bafa0d8c78566bbb3fe108dcb3985a20296c1 | |
| parent | dac3b592ed3940240eb8c0e3a25150049a87d416 (diff) | |
| download | seaweedfs-66317b843838f9eb63230d0916d525f75b8b30e2.tar.xz seaweedfs-66317b843838f9eb63230d0916d525f75b8b30e2.zip | |
Increase compact revision during each compaction
| -rw-r--r-- | go/storage/volume_vacuum.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/go/storage/volume_vacuum.go b/go/storage/volume_vacuum.go index 4f35a8149..251027771 100644 --- a/go/storage/volume_vacuum.go +++ b/go/storage/volume_vacuum.go @@ -65,6 +65,7 @@ func (v *Volume) copyDataAndGenerateIndexFile(dstName, idxName string) (err erro err = ScanVolumeFile(v.dir, v.Collection, v.Id, v.needleMapKind, func(superBlock SuperBlock) error { + superBlock.CompactRevision++ _, err = dst.Write(superBlock.Bytes()) return err }, true, func(n *Needle, offset int64) error { |