Skip to content

Commit

Permalink
read batch from DS
Browse files Browse the repository at this point in the history
  • Loading branch information
ToniRamirezM committed Jun 19, 2024
1 parent e995cdd commit 30a7eea
Showing 1 changed file with 7 additions and 5 deletions.
12 changes: 7 additions & 5 deletions tools/datastreamer/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -821,11 +821,13 @@ func (h *handler) handleReceivedDataStream(entry *datastreamer.FileEntry, client
}

// Finish the process
err = client.ExecCommandStop()
if err != nil {
log.Errorf("Error stopping the data stream: %v", err)
return err
}
/*
err = client.ExecCommandStop()
if err != nil {
log.Errorf("Error stopping the data stream: %v", err)
return err
}
*/
os.Exit(0)
return nil
case datastreamer.EntryType(datastream.EntryType_ENTRY_TYPE_L2_BLOCK):
Expand Down

0 comments on commit 30a7eea

Please sign in to comment.