Akka File Streaming throw error as akka.http.scaladsl.model.EntityStreamException: Entity stream truncation

860 Views Asked by At

We are Streaming file from S3 and processing it , after process complete we upload file back to S3 as Error / Archive file while streaming file from S3 it streams data and in between it stops processing with Error as "akka.http.scaladsl.model.EntityStreamException: Entity stream truncation" , Not sure is this depend on file size stream from S3 or corrupt file ?

val source = s3Client.download(baseConfig.bucketName.get, 
content.key)._1.via(Gzip.decoderFlow).
via(Framing.delimiter(ByteString("\n"), 256, 
byeFormatterFlag).map(_.utf8String))
val flow = flowDefintion(list)
val resp = source.via(flow).runWith(Sink.seq)

akka {
loglevel = "INFO"
stdout-loglevel = "INFO"
logging-filter = "akka.event.slf4j.Slf4jLoggingFilter"
http {
routing {
  decode-max-size = 25m
}
parsing {
  max-to-strict-bytes = 20m
  max-content-length = 20m
  max-chunk-size=10m
}

} }

0

There are 0 best solutions below