diff --git a/src/wal/log.go b/src/wal/log.go
index 0be86a09cb..49947fb82b 100644
--- a/src/wal/log.go
+++ b/src/wal/log.go
@@ -315,6 +315,7 @@ func (self *log) replayFromFileLocation(file *os.File,
 			return
 		}
 
+		req.RequestNumber = proto.Uint32(hdr.requestNumber)
 		replayRequest := &replayRequest{hdr.requestNumber, req, hdr.shardId, nil}
 		if sendOrStop(replayRequest, replayChan, stopChan) {
 			return
diff --git a/src/wal/wal_test.go b/src/wal/wal_test.go
index ea7d0ba5c4..55095de822 100644
--- a/src/wal/wal_test.go
+++ b/src/wal/wal_test.go
@@ -122,8 +122,6 @@ func (_ *WalSuite) TestLogFilesCompaction(c *C) {
 		c.Assert(id, Equals, uint32(i+1))
 	}
 	c.Assert(wal.logFiles, HasLen, 2)
-	wal.Close()
-
 	suffix := wal.logFiles[0].suffix()
 	c.Assert(wal.Commit(2001, 1), IsNil)
 	c.Assert(wal.logFiles, HasLen, 2)
@@ -251,6 +249,7 @@ func (_ *WalSuite) TestReplay(c *C) {
 	c.Assert(err, IsNil)
 	c.Assert(requests, HasLen, 1)
 	c.Assert(requests[0].Series.Points, HasLen, 3)
+	c.Assert(*requests[0].RequestNumber, Equals, uint32(3))
 	c.Assert(err, IsNil)
 }