From cca61b737e7d7a62217d0f0c421522f9f03adc92 Mon Sep 17 00:00:00 2001
From: Devdutt Shenoi <devdutt@parseable.com>
Date: Sun, 5 Jan 2025 13:27:19 +0530
Subject: [PATCH] fix: generic flattening only for non otel sources

---
 src/utils/json/mod.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/utils/json/mod.rs b/src/utils/json/mod.rs
index fd6992c72..9fb109552 100644
--- a/src/utils/json/mod.rs
+++ b/src/utils/json/mod.rs
@@ -38,7 +38,7 @@ pub fn flatten_json_body(
     let mut nested_value = if schema_version == SchemaVersion::V1
         && matches!(
             log_source,
-            LogSource::OtelLogs | LogSource::OtelMetrics | LogSource::OtelTraces
+            LogSource::Json | LogSource::Custom(_) | LogSource::Kinesis
         ) {
         flatten::generic_flattening(body)?
     } else {