checkpointing

12calore

1risposta

problemi di affidabilità con Checkpoint/WAL in Spark Streaming 1.6.0

Descrizione Abbiamo una scintilla Streaming 1.5.2 applicazione a Scala che legge gli eventi JSON da un Kinesis Stream, fa alcune trasformazioni/aggregazioni e scrive i risultati diversi prefissi S3. L