fix test

Author: zhyass

src/query/service/tests/it/storages/fuse/operations/table_analyze.rs

@@ -24,6 +24,7 @@ use databend_common_expression::ColumnId;
 use databend_common_expression::Scalar;
 use databend_common_io::prelude::borsh_deserialize_from_slice;
 use databend_common_storage::MetaHLL;
+use databend_common_storage::MetaHLL12;
 use databend_common_storages_fuse::io::MetaReaders;
 use databend_common_storages_fuse::io::MetaWriter;
 use databend_common_storages_fuse::statistics::reducers::merge_statistics_mut;
@@ -216,7 +217,8 @@ async fn test_table_analyze_without_prev_table_seq() -> Result<()> {
 
     // generate table statistics.
     let col: Vec<u8> = vec![1, 3, 0, 0, 0, 118, 5, 1, 21, 6, 3, 229, 13, 3];
-    let hll: HashMap<ColumnId, MetaHLL> = HashMap::from([(0, borsh_deserialize_from_slice(&col)?)]);
+    let meta: MetaHLL12 = borsh_deserialize_from_slice(&col)?;
+    let hll: HashMap<ColumnId, MetaHLL> = HashMap::from([(0, meta.into())]);
     let table_statistics =
         TableSnapshotStatistics::new(hll, HashMap::new(), snapshot_1.snapshot_id, 14);
     let table_statistics_location = location_gen.snapshot_statistics_location_from_uuid(

tests/sqllogictests/suites/base/09_fuse_engine/09_0020_analyze.test

@@ -129,7 +129,7 @@ analyze table `t`
 query TI
 select * from fuse_statistic('db_09_0020', 't')
 ----
-a 3 (empty)
+a 2 (empty)
 
 statement ok
 create or replace table t1 as select number as a from numbers(10);

tests/suites/1_stateful/09_http_handler/09_0008_forward.py

@@ -29,9 +29,12 @@ def do_query(query, port=8000, session=None, node_id=None, wait=100):
 
 
 def get_txn_state(resp):
-    return (resp.get("state") == "Succeeded",
-    resp.get("session").get("need_sticky"),
-    resp.get("session").get("txn_state"))
+    return (
+        resp.get("state") == "Succeeded",
+        resp.get("session").get("need_sticky"),
+        resp.get("session").get("txn_state"),
+    )
+
 
 def test_txn_success():
     resp = do_query("create or replace table t1(a int)").json()
@@ -63,22 +66,16 @@ def test_txn_fail():
     session = resp.get("session")
 
     # fail
-    resp = do_query(
-        "select 1/0",  session=session
-    ).json()
+    resp = do_query("select 1/0", session=session).json()
     assert get_txn_state(resp) == (False, False, "Fail"), resp
 
     # fail because wrong node
-    resp = do_query(
-        "select 1", port=8002, session=session
-    ).json()
+    resp = do_query("select 1", port=8002, session=session).json()
     session = resp.get("session")
     assert get_txn_state(resp) == (False, False, "Fail"), resp
 
     # keep fail state until commit/abort
-    resp = do_query(
-        "select 1", session=session, node_id=node_id
-    ).json()
+    resp = do_query("select 1", session=session, node_id=node_id).json()
     assert get_txn_state(resp) == (False, False, "Fail"), resp
     session = resp.get("session")