1. Home
  2. Docs
  3. Managing data quality
  4. Event Recovery for Snowplow Insights
  5. Running
  6. 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 Insights you can book a demo with our team, or if you’d prefer, you can try Snowplow technology for yourself quickly and easily.