From 95bcaa592763725dfc6c18d8ee1c10581d311f03 Mon Sep 17 00:00:00 2001 From: Ben Johnson Date: Tue, 19 Jan 2021 09:25:38 -0700 Subject: [PATCH] Fix file replica compression --- replica.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/replica.go b/replica.go index cfdbbd3..b60a49e 100644 --- a/replica.go +++ b/replica.go @@ -686,7 +686,7 @@ func (r *FileReplica) syncWAL(ctx context.Context) (err error) { // compress compresses all WAL files before the current one. func (r *FileReplica) compress(ctx context.Context, generation string) error { - filenames, err := filepath.Glob(filepath.Join(r.WALDir(generation), "**/*.wal")) + filenames, err := filepath.Glob(filepath.Join(r.WALDir(generation), "*.wal")) if err != nil { return err } else if len(filenames) <= 1 {