Sporadic error : akka.stream.alpakka.s3.impl.FailedUpload: Cannot find etag

Hi,

We have akka stream s3 download and upload implementation. When we run same testcase continuously for more than 10 times, the same testcase randomly fails with akka.stream.alpakka.s3.impl.FailedUpload: Cannot find etag. But, if we run the testcase again, it will succeed. We are using alpakka 0.16V. Any idea how to fix it.

   2018-04-04T17:59:18.41+0530 [APP/PROC/WEB/1] OUT Caused by: akka.stream.alpakka.s3.impl.FailedUpload: Cannot find etag
   2018-04-04T17:59:18.41+0530 [APP/PROC/WEB/1] OUT 	at akka.stream.alpakka.s3.impl.S3Stream.$anonfun$completionSink$2(S3Stream.scala:332) ~[akka-stream-alpakka-s3_2.12-0.16.jar!/:0.16]
   2018-04-04T17:59:18.41+0530 [APP/PROC/WEB/1] OUT 	at scala.concurrent.Future.$anonfun$flatMap$1(Future.scala:304) ~[scala-library-2.12.4.jar!/:?]
   2018-04-04T17:59:18.41+0530 [APP/PROC/WEB/1] OUT 	at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) ~[akka-actor_2.12-2.5.8.jar!/:?]
   2018-04-04T17:59:18.41+0530 [APP/PROC/WEB/1] OUT 	at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) ~[akka-actor_2.12-2.5.8.jar!/:?]
   2018-04-04T17:59:18.41+0530 [APP/PROC/WEB/1] OUT 	at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) ~[scala-library-2.12.4.jar!/:?]
   2018-04-04T17:59:18.41+0530 [APP/PROC/WEB/1] OUT 	at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) ~[akka-actor_2.12-2.5.8.jar!/:?]
   2018-04-04T17:59:18.41+0530 [APP/PROC/WEB/1] OUT 	at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) ~[scala-library-2.12.4.jar!/:?]
   2018-04-04T17:59:18.41+0530 [APP/PROC/WEB/1] OUT 	at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) ~[akka-actor_2.12-2.5.8.jar!/:?]
   2018-04-04T17:59:18.41+0530 [APP/PROC/WEB/1] OUT 	at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) ~[akka-actor_2.12-2.5.8.jar!/:?]
   2018-04-04T17:59:18.41+0530 [APP/PROC/WEB/1] OUT 	at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) ~[akka-actor_2.12-2.5.8.jar!/:?]
1 Like