Skip to content

Commit

Permalink
fix make check
Browse files Browse the repository at this point in the history
  • Loading branch information
amyangfei committed Apr 20, 2020
1 parent 3358ec7 commit 0d63bc7
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions cdc/puller/file_sorter.go
Original file line number Diff line number Diff line change
Expand Up @@ -291,9 +291,7 @@ func (fs *FileSorter) rotate(ctx context.Context, resolvedTs uint64) error {
}
atomic.StoreInt32(&fs.cache.sorting, 1)
files := make([]string, 0, len(fs.cache.unsortedFiles))
for _, f := range fs.cache.unsortedFiles {
files = append(files, f)
}
copy(files, fs.cache.unsortedFiles)
fs.cache.resetUnsortedFiles()
fs.cache.fileLock.Unlock()

Expand Down

0 comments on commit 0d63bc7

Please sign in to comment.