Skip to content

Commit

Permalink
Add chunk file support
Browse files Browse the repository at this point in the history
  • Loading branch information
yzang2019 committed Oct 7, 2023
1 parent ab545cd commit a7fe73c
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion changeset/export.go
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,8 @@ func (exporter *Exporter) Start() error {
if err := group.Wait(); err != nil {
return err
}
err := collectChunksToSegment(exporter.outputDir, chunkFiles)
segmentFile := filepath.Join(exporter.outputDir, fmt.Sprintf("changeset-%d-%d.zst", i, end))
err := collectChunksToSegment(segmentFile, chunkFiles)
if err != nil {
return err
}
Expand Down

0 comments on commit a7fe73c

Please sign in to comment.