From 2a44a25a9d3d7c744004b175c7dcfc22ce09fbcb Mon Sep 17 00:00:00 2001 From: gmhdbjd Date: Fri, 25 Nov 2022 12:24:18 +0800 Subject: [PATCH] fix ut --- dm/relay/local_reader_test.go | 1 + 1 file changed, 1 insertion(+) 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 {