[ClickHouse org] Prevent inserting logs with timestamp=epoch

When the pipeline fails to parse a timestamp, just use the observed timestamp rather than 1970
ClickHouse · Jan 10, 2024 · 8ef725a · 8ef725a
1 parent 2a5822e
commit 8ef725a
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/exporter/clickhouseexporter/exporter_logs.go b/exporter/clickhouseexporter/exporter_logs.go
@@ -88,8 +88,12 @@ func (e *logsExporter) pushLogsData(ctx context.Context, ld plog.Logs) error {
 				for k := 0; k < rs.Len(); k++ {
 					r := rs.At(k)
 					logAttr := attributesToMap(r.Attributes())
+					insertTimestamp := r.Timestamp()
+					if insertTimestamp == 0 {
+						insertTimestamp = r.ObservedTimestamp()
+					}
 					_, err = statement.ExecContext(ctx,
-						r.Timestamp().AsTime(),
+						insertTimestamp.AsTime(),
 						traceutil.TraceIDToHexOrEmptyString(r.TraceID()),
 						traceutil.SpanIDToHexOrEmptyString(r.SpanID()),
 						uint32(r.Flags()),