In the context of developing a data processing pipeline using Google Cloud services, you are tasked with streaming IoT data from Cloud Pub/Sub through Cloud Dataflow to BigQuery. During the preview phase of the data, you observe that approximately 2% of the data is corrupt. What steps would you take to update the Cloud Dataflow pipeline in order to filter out the corrupt data?