storage/sqlite/direct.go | 3 +++

diff --git a/storage/sqlite/direct.go b/storage/sqlite/direct.go
index 7748f92182780789be65f590c9389d119cbd91c3..899cf1af3dd2646f46152c68b048e1a940650594 100644
--- a/storage/sqlite/direct.go
+++ b/storage/sqlite/direct.go
@@ -58,6 +58,9 @@ 		conn:  conn,
 		blobs: make(map[string]*sqlite.Blob),
 		opts:  opts,
 	}
+	// Avoid race with cl.blobFlusherFunc
+	cl.l.Lock()
+	defer cl.l.Unlock()
 	if opts.BlobFlushInterval != 0 {
 		cl.blobFlusher = time.AfterFunc(opts.BlobFlushInterval, cl.blobFlusherFunc)
 	}