1. Home
  2. Docs
  3. Managing data quality
  4. Event Recovery for Open Source
  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