starred/openobserve
1
0
Fork 0
mirror of https://github.com/openobserve/openobserve.git synced 2026-11-06 08:09:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf: tradeof between query performance and ingester performance (#2842)

Browse Source 
close #2839
This commit is contained in:
Huaijin
2024-03-01 21:46:57 +05:30
committed by GitHub
parent 0f400b0efb
commit cf5cb0b9a7
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/service/logs/mod.rs
+3 -7
View File
@@ -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