diff --git a/server/ingester/pkg/ckwriter/ckwriter.go b/server/ingester/pkg/ckwriter/ckwriter.go index a593f4ab7f7..f459c9fd513 100644 --- a/server/ingester/pkg/ckwriter/ckwriter.go +++ b/server/ingester/pkg/ckwriter/ckwriter.go @@ -184,8 +184,7 @@ func initTable(conn clickhouse.Conn, timeZone string, t *ckdb.Table, orgID uint1 return err } - // after Byconity creates the '1h' and '1d' tables, the query for the '1m' table will fail - if t.Aggr1H1D && t.DBType != ckdb.CKDBTypeByconity { + if t.Aggr1H1D { if err := ExecSQL(conn, t.MakeAggrTableCreateSQL1H(orgID)); err != nil { log.Warningf("create 1h agg table failed: %s", err) } diff --git a/server/libs/ckdb/table.go b/server/libs/ckdb/table.go index 3c03d6fe7f6..67aff7f715b 100644 --- a/server/libs/ckdb/table.go +++ b/server/libs/ckdb/table.go @@ -73,10 +73,8 @@ func (a AggregationInterval) ByconityBaseTable() string { switch a { case AggregationMinute: return "1s" - case AggregationHour: + case AggregationHour, AggregationDay: return "1m" - case AggregationDay: - return "1h_agg" default: return "unkunown aggregation byconity base table" }