From cf5cb0b9a7f697d76fcfe302bfb64a9068829368 Mon Sep 17 00:00:00 2001
From: Huaijin <haohuaijin@gmail.com>
Date: Sat, 2 Mar 2024 00:16:57 +0800
Subject: [PATCH] perf: tradeof between query performance and ingester
 performance (#2842)

close #2839
---
 src/service/logs/mod.rs | 10 +++-------
 1 file changed, 3 insertions(+), 7 deletions(-)

diff --git a/src/service/logs/mod.rs b/src/service/logs/mod.rs
index 2b3cd99a79..469d581505 100644
--- a/src/service/logs/mod.rs
+++ b/src/service/logs/mod.rs
@@ -165,7 +165,7 @@ async fn add_valid_record(
         .unwrap();
 
     // check schema
-    let (schema_evolution, infer_schema) = check_for_schema(
+    let (schema_evolution, _) = check_for_schema(
         &stream_meta.org_id,
         &stream_meta.stream_name,
         StreamType::Logs,
@@ -175,12 +175,8 @@ async fn add_valid_record(
     )
     .await?;
 
-    // get record schema
-    let schema_latest = stream_schema_map.get(&stream_meta.stream_name).unwrap();
-    let rec_schema = match infer_schema.as_ref() {
-        Some(v) => v,
-        None => schema_latest,
-    };
+    // get schema
+    let rec_schema = stream_schema_map.get(&stream_meta.stream_name).unwrap();
     let schema_key = rec_schema.hash_key();
 
     // get hour key