fix : Loading line protocol data indicates insufficient memory #1109

main/src/main.rs

@@ -191,7 +191,7 @@ fn main() -> Result<(), std::io::Error> {
     init_tskv_metrics_recorder();
 
     let runtime = Arc::new(init_runtime(Some(config.deployment.cpu))?);
-    let mem_bytes = run_args.cpu.unwrap_or(config.deployment.memory) * 1024 * 1024 * 1024;
+    let mem_bytes = run_args.memory.unwrap_or(config.deployment.memory) * 1024 * 1024 * 1024;
     let memory_pool = Arc::new(GreedyMemoryPool::new(mem_bytes));
     runtime.clone().block_on(async move {
         let builder = server::ServiceBuilder {

query_server/query/src/extension/analyse/transform_gapfill/mod.rs

@@ -402,7 +402,7 @@ fn handle_projection(proj: &Projection) -> Result<Option<LogicalPlan>> {
     }) else {
         // If this is not a projection that is a parent to a GapFill node,
         // then there is nothing to do.
-        return Ok(None)
+        return Ok(None);
     };
 
     let fill_cols: Vec<(&Expr, FillStrategy, &str)> = proj_exprs

tskv/Cargo.toml

@@ -58,11 +58,11 @@ walkdir = { workspace = true }
 zstd = { workspace = true }
 tonic = { workspace = true }
 
-[target.'cfg(linux)'.dependencies]
+[target.'cfg(target_os = "linux")'.dependencies]
 rio = { version = "0.9", optional = true }
 tokio-uring = { version = "0.4", optional = true }
 
-[target.'cfg(windows)'.dependencies]
+[target.'cfg(target_os = "windows")'.dependencies]
 winapi = { workspace = true }