fix for count distinct

nikhilsinhaparseable · nikhilsinhaparseable · commit a2e93f3e2c90 · 2025-07-25T02:47:31.000-07:00
diff --git a/src/alerts/mod.rs b/src/alerts/mod.rs
@@ -699,7 +699,7 @@ impl AlertConfig {
         let query = match aggregate_function {
             AggregateFunction::CountDistinct => {
                 if column == "*" {
-                    format!("SELECT COUNT(DISTINCT *) as alert_value FROM \"{stream}\"")
+                    format!("SELECT COUNT(*) as alert_value FROM \"{stream}\"")
                 } else {
                     format!("SELECT COUNT(DISTINCT \"{column}\") as alert_value FROM \"{stream}\"")
                 }

Original file line number	Diff line number	Diff line change
`@@ -699,7 +699,7 @@ impl AlertConfig {`
`699`	`699`	`let query = match aggregate_function {`
`700`	`700`	`AggregateFunction::CountDistinct => {`
`701`	`701`	`if column == "*" {`
`702`		`- format!("SELECT COUNT(DISTINCT *) as alert_value FROM \"{stream}\"")`
	`702`	`+ format!("SELECT COUNT(*) as alert_value FROM \"{stream}\"")`
`703`	`703`	`} else {`
`704`	`704`	`format!("SELECT COUNT(DISTINCT \"{column}\") as alert_value FROM \"{stream}\"")`
`705`	`705`	`}`