How do you detect and handle data anomalies or dropped packets in a continuous data stream for GE Vernova telemetry pipelines?