diff --git a/akka-distributed-data/src/main/scala/akka/cluster/ddata/DurableStore.scala b/akka-distributed-data/src/main/scala/akka/cluster/ddata/DurableStore.scala
index 78a529cef8..621dd609ca 100644
--- a/akka-distributed-data/src/main/scala/akka/cluster/ddata/DurableStore.scala
+++ b/akka-distributed-data/src/main/scala/akka/cluster/ddata/DurableStore.scala
@@ -67,7 +67,7 @@ object DurableStore {
   case object LoadAll
   final case class LoadData(data: Map[String, ReplicatedData])
   case object LoadAllCompleted
-  class LoadFailed(message: String, cause: Throwable) extends RuntimeException(message) {
+  class LoadFailed(message: String, cause: Throwable) extends RuntimeException(message, cause) {
     def this(message: String) = this(message, null)
   }
 
diff --git a/akka-distributed-data/src/main/scala/akka/cluster/ddata/Replicator.scala b/akka-distributed-data/src/main/scala/akka/cluster/ddata/Replicator.scala
index 54b51b8054..23c997e705 100644
--- a/akka-distributed-data/src/main/scala/akka/cluster/ddata/Replicator.scala
+++ b/akka-distributed-data/src/main/scala/akka/cluster/ddata/Replicator.scala
@@ -910,7 +910,7 @@ final class Replicator(settings: ReplicatorSettings) extends Actor with ActorLog
     OneForOneStrategy()(
       ({
         case e @ (_: DurableStore.LoadFailed | _: ActorInitializationException) if fromDurableStore ⇒
-          log.error(e, "Stopping distributed-data Replicator due to load or startup failure in durable store")
+          log.error(e, "Stopping distributed-data Replicator due to load or startup failure in durable store, caused by: {}", if (e.getCause eq null) "" else e.getCause.getMessage)
           context.stop(self)
           SupervisorStrategy.Stop
       }: SupervisorStrategy.Decider).orElse(SupervisorStrategy.defaultDecider))