fix: ignoring the query result in ByConity cause a failure

deepflowio · Jan 20, 2025 · 97142e9 · 97142e9
1 parent 698a715
commit 97142e9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/libs/ckdb/table.go b/server/libs/ckdb/table.go
@@ -511,7 +511,7 @@ FROM %s`,
 
 func (t *Table) MakeAggrGlobalTableCreateSQL(orgID uint16, aggrInterval AggregationInterval) string {
 	if t.DBType == CKDBTypeByconity {
-		return "SELECT VERSION()"
+		return t.MakeAggrLocalTableCreateSQL(orgID, aggrInterval)
 	}
 	tableGlobal := fmt.Sprintf("%s.%s", t.tablePrefix(), aggrInterval.String())
 	tableLocal := fmt.Sprintf("%s.%s_local", t.tablePrefix(), aggrInterval.String())