From 3e9e416706e03a9980928f196d91a721711b5404 Mon Sep 17 00:00:00 2001 From: Leonardo Yvens Date: Sat, 21 Mar 2026 17:24:07 +0000 Subject: [PATCH] perf(common): lookup blocks table by _block_num --- crates/core/common/src/streaming_query.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/crates/core/common/src/streaming_query.rs b/crates/core/common/src/streaming_query.rs index 3949c9a54..610099df5 100644 --- a/crates/core/common/src/streaming_query.rs +++ b/crates/core/common/src/streaming_query.rs @@ -865,7 +865,7 @@ impl StreamingQuery { .unwrap_or_default(); let (blocks_physical_table, blocks_sql_schema_name) = &self.blocks_table; let sql = format!( - "SELECT hash, parent_hash, timestamp FROM {} WHERE block_num = {} {} LIMIT 1", + "SELECT hash, parent_hash, timestamp FROM {} WHERE _block_num = {} {} LIMIT 1", TableReference::Partial { schema: Arc::new(blocks_sql_schema_name.to_string()), table: Arc::new(blocks_physical_table.table_name().clone()),