Fix file replica compression

This commit is contained in:
Ben Johnson
2021-01-19 09:25:38 -07:00
parent 1935ebd6f0
commit 95bcaa5927

View File

@@ -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 {