1. Home
  2. Docs
  3. Managing data quality
  4. Event Recovery for BDP customers
  5. Manual Event Recovery for Snowplow BDP
  6. Running
  7. Flink


The Flink job reads bad rows from an S3 location and stores the recovered payloads in Kinesis, unrecovered and unrecoverable in other S3 buckets.


To build the fat jar, run:

sbt flink/assembly


Using flink CLI:

flink run \ snowplow-event-recovery-flink-0.2.0.jar \ --input s3://bad-rows-location/** \ --output recovered-kinesis-topic \ --failedOutput s3://unrecovered-collector-payloads-location/ \ --unrecoverableOutput s3://unrecoverable-collector-payloads-location/ \ --config $JOB_CONFIG \ --resolver $RESOLVER_CONFIG
Code language: PHP (php)

If you’d like to learn more about Snowplow BDP you can book a demo with our team, or if you’d prefer, you can try Snowplow technology for yourself quickly and easily.