fix(query): table system.query_execution output data type does not match definition (#18554)

fix

Author: forsaken628

src/query/storages/system/src/query_execution_table.rs

@@ -24,7 +24,7 @@ use databend_common_exception::Result;
 use databend_common_expression::types::NumberDataType;
 use databend_common_expression::types::StringType;
 use databend_common_expression::types::TimestampType;
-use databend_common_expression::types::UInt32Type;
+use databend_common_expression::types::UInt64Type;
 use databend_common_expression::ColumnBuilder;
 use databend_common_expression::DataBlock;
 use databend_common_expression::FromData;
@@ -183,17 +183,17 @@ impl QueryExecutionTable {
                 nodes.push(local_id.clone());
                 timestamps.push(timestamp as i64 * 1_000_000);
                 query_ids.push(query_id.clone());
-                process_rows.push(rows_for_timestamp.get(query_id).copied().unwrap_or(0));
-                process_times.push(times_for_timestamp.get(query_id).copied().unwrap_or(0));
+                process_rows.push(rows_for_timestamp.get(query_id).copied().unwrap_or(0) as u64);
+                process_times.push(times_for_timestamp.get(query_id).copied().unwrap_or(0) as u64);
             }
         }
 
         Ok(vec![
             StringType::from_data(nodes),
             TimestampType::from_data(timestamps),
             StringType::from_data(query_ids),
-            UInt32Type::from_data(process_rows),
-            UInt32Type::from_data(process_times),
+            UInt64Type::from_data(process_rows),
+            UInt64Type::from_data(process_times),
         ])
     }
 }

src/query/storages/system/src/table.rs

@@ -203,7 +203,22 @@ impl<TTable: 'static + SyncSystemTable> SyncSource for SystemTableSyncSource<TTa
         }
 
         self.finished = true;
-        Ok(Some(self.inner.get_full_data(self.context.clone())?))
+        let block = self.inner.get_full_data(self.context.clone())?;
+        #[cfg(debug_assertions)]
+        {
+            let schema = self.inner.get_table_info().schema();
+            for (field, column) in schema.fields.iter().zip(block.columns().iter()) {
+                assert_eq!(
+                    column.data_type(),
+                    field.data_type().into(),
+                    "table_schema: {:?}, block_schema: {:?}",
+                    schema,
+                    block.infer_schema()
+                );
+            }
+        }
+
+        Ok(Some(block))
     }
 }