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

Commit e9d2db5

Browse files
authored
Log failed ingest statements (#1346)
1. Let's log full statement which failed, sometimes it's hard to decipher what went wrong just by looking at the error 2. It's not `query`, this part of code handles ingest statements.
1 parent 06bdc8a commit e9d2db5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

platform/ingest/processor.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -878,7 +878,8 @@ func (ip *IngestProcessor) executeStatements(ctx context.Context, queries []stri
878878

879879
err := ip.execute(ctx, q)
880880
if err != nil {
881-
logger.ErrorWithCtx(ctx).Msgf("error executing query: %v", err)
881+
logger.DebugWithCtx(ctx).Msgf("error=[%v] while executing statement=[%s]", err, q)
882+
logger.ErrorWithCtx(ctx).Msgf("error executing statement: %v", err)
882883
return err
883884
}
884885
}

0 commit comments

Comments
 (0)