File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -580,13 +580,17 @@ func GetVmStatus(conf *model.CKManClickHouseConfig) (map[string]*model.CkVmStatu
580580 if err != nil {
581581 return nil , err
582582 }
583+ uncompressed := "sum(0)"
584+ if common .CompareClickHouseVersion (conf .Version , "24.8.x" ) >= 0 {
585+ uncompressed = "sum(total_bytes_uncompressed)"
586+ }
583587 query := fmt .Sprintf (`SELECT
584588 database,
585589 name,
586590 sum(parts),
587591 sum(total_rows),
588592 sum(total_bytes),
589- sum(total_bytes_uncompressed) ,
593+ %s ,
590594 (extractAllGroups(as_select, 'FROM ([\\w\\d_]+\\.[\\w+\\d_]+)')[1])[1] AS source_table,
591595 as_select
592596FROM cluster('%s', system.tables)
@@ -595,7 +599,7 @@ GROUP BY
595599 database,
596600 name,
597601 source_table,
598- as_select` , conf .Cluster )
602+ as_select` , uncompressed , conf .Cluster )
599603
600604 data , err := service .QueryInfo (query )
601605 if err != nil {
You can’t perform that action at this time.
0 commit comments