diff --git a/cmd/changeset/changeset/export.go b/cmd/changeset/changeset/export.go
index b5214d2..a1bc9d2 100644
--- a/cmd/changeset/changeset/export.go
+++ b/cmd/changeset/changeset/export.go
@@ -29,7 +29,7 @@ type CSExporter struct {
 	outputDir   string
 }
 
-func NewCSExporter(db *dbm.PrefixDB, start, end int64, concurrency int, segmentSize int, outputDir string) *CSExporter {
+func NewCSExporter(db *dbm.PrefixDB, start int64, end int64, concurrency int, segmentSize int, outputDir string) *CSExporter {
 	return &CSExporter{
 		db:          db,
 		start:       start,
diff --git a/cmd/changeset/main.go b/cmd/changeset/main.go
index 38343f9..e189ffd 100644
--- a/cmd/changeset/main.go
+++ b/cmd/changeset/main.go
@@ -37,7 +37,7 @@ func ExportChangeSetCmd() *cobra.Command {
 	}
 	cmd.PersistentFlags().Int64("start-version", 0, "start version number")
 	cmd.PersistentFlags().Int64("end-version", 0, "end version number")
-	cmd.PersistentFlags().Int64("concurrency", 10, "number of concurrent workers")
+	cmd.PersistentFlags().Int("concurrency", 10, "number of concurrent workers")
 	cmd.PersistentFlags().Int64("segment-size", 1000000, "number of blocks in each segment")
 
 	// we handle one stores at a time, because stores don't share much in db, handle concurrently reduces cache efficiency.