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()),