Entity recovery timeout should back off
negokaz opened this issue · 0 comments
negokaz commented
Simple retries may induce failures
case RaftProtocol.RecoveryTimeout => context.log.info( "Entity (name: {}) recovering timed out. It will be retried later.", setup.entityContext.entityId, ) // TODO: Enable backoff to prevent cascade failures throw RaftProtocol.EntityRecoveryTimeoutException(context.self.path)
override def stateReceive(receive: Receive, message: Any): Unit = message match { case RecoveryTimeout => // to restart // TODO: BackoffSupervisor を使ってカスケード障害を回避する log.info("Entity (name: {}) recovering timed out. It will be retried later.", self.path.name) throw EntityRecoveryTimeoutException(self.path)