Skip to content
This repository was archived by the owner on Feb 17, 2025. It is now read-only.

Commit 8335850

Browse files
authored
fix query DS by batch (#3803)
1 parent 596741e commit 8335850

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

tools/datastreamer/main.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -685,8 +685,9 @@ func decodeBatch(cliCtx *cli.Context) error {
685685
batchData = append(batchData, entry.Encode()...)
686686

687687
i := uint64(1) //nolint:gomnd
688+
start := entry.Number
688689
for {
689-
entry, err := client.ExecCommandGetEntry(entry.Number + i)
690+
entry, err := client.ExecCommandGetEntry(start + i)
690691
if err != nil {
691692
log.Error(err)
692693
os.Exit(1)
@@ -760,8 +761,9 @@ func decodeBatchOffline(cliCtx *cli.Context) error {
760761
i := uint64(1) //nolint:gomnd
761762
printEntry(entry, shouldPrintJson)
762763
batchData = append(batchData, entry.Encode()...)
764+
start := entry.Number
763765
for {
764-
entry, err = streamServer.GetEntry(entry.Number + i)
766+
entry, err = streamServer.GetEntry(start + i)
765767
if err != nil {
766768
log.Error(err)
767769
os.Exit(1)

0 commit comments

Comments
 (0)