diff --git a/dm/relay/local_reader_test.go b/dm/relay/local_reader_test.go
index 0480e92b6cf..df6c33fbd81 100644
--- a/dm/relay/local_reader_test.go
+++ b/dm/relay/local_reader_test.go
@@ -79,6 +79,7 @@ func (t *testReaderSuite) setActiveRelayLog(r Process, uuid, filename string, of
 	writer.out.uuid.Store(uuid)
 	writer.out.filename.Store(filename)
 	writer.out.offset.Store(offset)
+	writer.out.fileOffset.Store(offset)
 }
 
 func (t *testReaderSuite) createBinlogFileParseState(c *C, relayLogDir, relayLogFile string, offset int64, possibleLast bool) *binlogFileParseState {