diff --git a/rust/otap-dataflow/crates/otap/src/filter_processor.rs b/rust/otap-dataflow/crates/otap/src/filter_processor.rs
index 98e9d60461..d804431d87 100644
--- a/rust/otap-dataflow/crates/otap/src/filter_processor.rs
+++ b/rust/otap-dataflow/crates/otap/src/filter_processor.rs
@@ -113,7 +113,8 @@ impl local::Processor<OtapPdata> for FilterProcessor {
                 // convert to arrow records
                 let (context, payload) = pdata.into_parts();
 
-                let arrow_records: OtapArrowRecords = payload.try_into()?;
+                let mut arrow_records: OtapArrowRecords = payload.try_into()?;
+                arrow_records.decode_transport_optimized_ids()?;
 
                 let filtered_arrow_records: OtapArrowRecords = match signal {
                     SignalType::Metrics => {