Use correct error variable for wrapped error

SigNoz · Aug 23, 2024 · 2d185f2 · 2d185f2
1 parent 9c3fe7f
commit 2d185f2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/exporter/clickhouselogsexporter/exporter.go b/exporter/clickhouselogsexporter/exporter.go
@@ -191,7 +191,7 @@ func (e *clickhouseLogsExporter) pushLogsData(ctx context.Context, ld plog.Logs)
  if err != nil {
  // StatementSend:code: 252, message: Too many partitions for single INSERT block
  // iterating twice since we want to try once after removing the old data
- if i == 1 || !strings.Contains(err.Error(), "StatementSend:code: 252") {
+ if i == 1 || !strings.Contains(err.Error(), "code: 252") {
  // TODO(nitya): after returning it will be retried, ideally it should be pushed to DLQ
  return err
  }
@@ -439,7 +439,7 @@ func (e *clickhouseLogsExporter) pushToClickhouse(ctx context.Context, ld plog.L
  // check the errors
  for i := 0; i < 3; i++ {
  if r := <-chErr; r != nil {
- return fmt.Errorf("StatementSend:%w", err)
+ return fmt.Errorf("StatementSend:%w", r)
  }
  }