Files
lingniu-vehicle-ingest/vehicle-data-platform/deploy/migrations/011_alert_stream_invalid_evidence.sql

7 lines
315 B
SQL

ALTER TABLE vehicle_alert_stream_checkpoint
ADD COLUMN last_invalid_code VARCHAR(64) NOT NULL DEFAULT '' AFTER last_source_event_id,
ADD COLUMN last_invalid_at DATETIME(3) NULL AFTER last_invalid_code;
CREATE INDEX idx_alert_stream_invalid
ON vehicle_alert_stream_checkpoint(consumer_group,last_invalid_at);