@Dmitriy_Tarasevich, Snowplow Event Recovery won’t work on shredded data. It’s meant to recover bad events generated by the real-time pipeline (events rejected at enrichment stage).
I assume you are running real-time pipeline. For batch, you would need to use a different recovery app as per tutorial Running Hadoop Event Recovery with Dataflow Runner [tutorial].
It appears you are trying to recover a custom event which is missing a required field. The strategy you have chosen for that, PassThrough
, is not correct unless you have modified your JSON schema which now does not require that field. My understanding is you would want to insert a missing property into the event with presumably a default value. You likely need to choose a different strategy for this task.