cameleer-server-app/src/main/resources/clickhouse/alerting_projections.sql

@@ -1,12 +1,12 @@
 -- Alerting projections — additive and idempotent (IF NOT EXISTS).
 -- Safe to run on every startup alongside init.sql.
 --
--- NOTE: executions uses ReplacingMergeTree which requires deduplicate_merge_projection_mode='rebuild'
--- to support projections (ClickHouse 24.x). The ADD PROJECTION and MATERIALIZE statements for
--- executions are treated as best-effort by the schema initializer (non-fatal on failure).
--- logs and agent_metrics use plain MergeTree and always succeed.
+-- executions uses ReplacingMergeTree. ClickHouse 24.x requires deduplicate_merge_projection_mode='rebuild'
+-- for projections to work on ReplacingMergeTree. ALTER TABLE MODIFY SETTING persists the setting in
+-- table metadata (survives restarts) and runs before the ADD PROJECTION statements.
+-- logs and agent_metrics use plain MergeTree and do not need this setting.
 --
--- MATERIALIZE statements are also wrapped as non-fatal to handle empty tables in fresh deployments.
+-- MATERIALIZE statements are wrapped as non-fatal to handle empty tables in fresh deployments.
 
 -- Plain MergeTree tables: always succeed
 ALTER TABLE logs
@@ -17,7 +17,9 @@ ALTER TABLE agent_metrics
     ADD PROJECTION IF NOT EXISTS alerting_instance_metric
     (SELECT * ORDER BY (tenant_id, environment, instance_id, metric_name, collected_at));
 
--- ReplacingMergeTree tables: best-effort (requires deduplicate_merge_projection_mode='rebuild')
+-- ReplacingMergeTree: set table-level setting so ADD PROJECTION succeeds on any connection
+ALTER TABLE executions MODIFY SETTING deduplicate_merge_projection_mode = 'rebuild';
+
 ALTER TABLE executions
     ADD PROJECTION IF NOT EXISTS alerting_app_status
     (SELECT * ORDER BY (tenant_id, environment, application_id, status, start_time));

cameleer-server-app/src/test/java/com/cameleer/server/app/search/AlertingProjectionsIT.java

@@ -34,17 +34,19 @@ class AlertingProjectionsIT {
     }
 
     @Test
-    void mergeTreeProjectionsExistAfterInit() {
-        // logs and agent_metrics are plain MergeTree — projections always succeed.
-        // executions is ReplacingMergeTree; its projections require the session setting
-        // deduplicate_merge_projection_mode='rebuild' which is unavailable via JDBC pool,
-        // so they are best-effort and not asserted here.
+    void allFourProjectionsExistAfterInit() {
+        // logs and agent_metrics are plain MergeTree — always succeed.
+        // executions is ReplacingMergeTree; its projections now succeed because
+        // alerting_projections.sql runs ALTER TABLE executions MODIFY SETTING
+        // deduplicate_merge_projection_mode='rebuild' before the ADD PROJECTION statements.
         List<String> names = jdbc.queryForList(
-                "SELECT name FROM system.projections WHERE table IN ('logs', 'agent_metrics')",
+                "SELECT name FROM system.projections WHERE table IN ('logs', 'agent_metrics', 'executions')",
                 String.class);
 
-        assertThat(names).contains(
+        assertThat(names).containsExactlyInAnyOrder(
                 "alerting_app_level",
-                "alerting_instance_metric");
+                "alerting_instance_metric",
+                "alerting_app_status",
+                "alerting_route_status");
     }
 }