diff --git a/client/batch.go b/client/batch.go index 4fa326f80..87a8952ee 100644 --- a/client/batch.go +++ b/client/batch.go @@ -700,9 +700,7 @@ func (b *Batch) Import() error { // import int data. err = b.doImport(frags, clearFrags) if err != nil { - // doImport actually imports the ingested data. An error here, means an error with the value that is trying to be ingested. - // We log the error, so we can continue ingesting. Returning would stop the ingest. - b.log.Printf("error importing batch: %v", err) + return errors.Wrap(err, "doing import") } b.log.Printf("importing fragments took %v", time.Since(makeTime)) }