I'm seeing the same entries in my log, but everything is working just fine.
I haven't looked into it yet, but I'm wondering what is the cause of this
message. There are a lot of these kind of logging entries in my log and
they appear on every startup of my app.
Cheers,
Jeroen
Op woensdag 22 oktober 2014 09:06:16 UTC+2 schreef Patrik Nordwall:
>
> I don't think this is anything to worry about, but let us know if you find
> anything that is not working as expected.
>
> Regards,
> Patrik
>
> On Mon, Oct 20, 2014 at 6:59 PM, Richard Rodseth <rrod...@gmail.com
> <javascript:>> wrote:
>
>> Yes, I'm using 2.3.6. I *think* the result is still correct, but haven't
>> had time to verify.
>> It also happens in an app that does nothing more than instantiate a
>> persistent view
>>
>> object AuditPersistentActor extends App {
>>
>> println("Audit persistent actor app")
>>
>> implicit val system = ActorSystem("audit-persistent-actor-test")
>>
>> val view = system.actorOf(SamplePersistentView.props("id-1"))
>>
>> }
>>
>> [DEBUG] [10/20/2014 09:56:44.240] [main]
>> [EventStream(akka://audit-persistent-actor-test)] logger
>> log1-Logging$DefaultLogger started
>>
>> [DEBUG] [10/20/2014 09:56:44.241] [main]
>> [EventStream(akka://audit-persistent-actor-test)] Default Loggers started
>>
>> [DEBUG] [10/20/2014 09:56:44.655]
>> [audit-persistent-actor-test-akka.persistence.dispatchers.default-replay-dispatcher-9]
>>
>> [akka.serialization.Serialization(akka://audit-persistent-actor-test)]
>> Using serializer[akka.persistence.serialization.MessageSerializer] for
>> message [akka.persistence.PersistentRepr]
>>
>> [DEBUG] [10/20/2014 09:56:44.712]
>> [audit-persistent-actor-test-akka.persistence.dispatchers.default-replay-dispatcher-9]
>>
>> [LocalActorRefProvider(akka://audit-persistent-actor-test)] resolve of
>> unknown path [akka://create-persistent-actors-test/deadLetters] failed
>>
>> [DEBUG] [10/20/2014 09:56:44.716]
>> [audit-persistent-actor-test-akka.persistence.dispatchers.default-replay-dispatcher-9]
>>
>> [LocalActorRefProvider(akka://audit-persistent-actor-test)] resolve of
>> unknown path [akka://create-persistent-actors-test/deadLetters] failed
>>
>> [DEBUG] [10/20/2014 09:56:44.717]
>> [audit-persistent-actor-test-akka.persistence.dispatchers.default-replay-dispatcher-9]
>>
>> [LocalActorRefProvider(akka://audit-persistent-actor-test)] resolve of
>> unknown path [akka://create-persistent-actors-test/deadLetters] failed
>>
>> [DEBUG] [10/20/2014 09:56:44.717]
>> [audit-persistent-actor-test-akka.actor.default-dispatcher-3]
>> [akka://audit-persistent-actor-test/user/$a] Received from journal
>> AggregateAdded(initial content)
>>
>> [DEBUG] [10/20/2014 09:56:44.717]
>> [audit-persistent-actor-test-akka.actor.default-dispatcher-3]
>> [akka://audit-persistent-actor-test/user/$a] Received from journal
>> ContentChanged(Sat Oct 18 11:14:48 PDT 2014)
>>
>> [DEBUG] [10/20/2014 09:56:44.717]
>> [audit-persistent-actor-test-akka.persistence.dispatchers.default-replay-dispatcher-9]
>>
>> [LocalActorRefProvider(akka://audit-persistent-actor-test)] resolve of
>> unknown path [akka://create-persistent-actors-test/deadLetters] failed
>>
>> [DEBUG] [10/20/2014 09:56:44.717]
>> [audit-persistent-actor-test-akka.actor.default-dispatcher-3]
>> [akka://audit-persistent-actor-test/user/$a] Received from journal
>> ContentChanged(Sat Oct 18 11:16:47 PDT 2014)
>>
>> [DEBUG] [10/20/2014 09:56:44.717]
>> [audit-persistent-actor-test-akka.actor.default-dispatcher-3]
>> [akka://audit-persistent-actor-test/user/$a] Received from journal
>> ContentChanged(Sat Oct 18 11:25:44 PDT 2014)
>>
>> [DEBUG] [10/20/2014 09:56:44.718]
>> [audit-persistent-actor-test-akka.persistence.dispatchers.default-replay-dispatcher-9]
>>
>> [LocalActorRefProvider(akka://audit-persistent-actor-test)] resolve of
>> unknown path [akka://create-persistent-actors-test/deadLetters] failed
>>
>> [DEBUG] [10/20/2014 09:56:44.718]
>> [audit-persistent-actor-test-akka.actor.default-dispatcher-3]
>> [akka://audit-persistent-actor-test/user/$a] Received from journal
>> ContentChanged(Sat Oct 18 11:27:14 PDT 2014)
>>
>> [DEBUG] [10/20/2014 09:56:44.718]
>> [audit-persistent-actor-test-akka.persistence.dispatchers.default-replay-dispatcher-9]
>>
>> [LocalActorRefProvider(akka://audit-persistent-actor-test)] resolve of
>> unknown path [akka://create-persistent-actors-test/deadLetters] failed
>>
>> [DEBUG] [10/20/2014 09:56:44.718]
>> [audit-persistent-actor-test-akka.actor.default-dispatcher-3]
>> [akka://audit-persistent-actor-test/user/$a] Received from journal
>> ContentChanged(Sat Oct 18 11:27:42 PDT 2014)
>>
>> On Mon, Oct 20, 2014 at 12:59 AM, Patrik Nordwall <patrik....@gmail.com
>> <javascript:>> wrote:
>>
>>> Hi Richard,
>>>
>>> I don't know from where the "resolve of unknown path" originates. I
>>> would guess it is something from deserialization.
>>> It is logged at debug level. Is the result still correct?
>>>
>>> Are you using Akka 2.3.6?
>>>
>>> Regards,
>>> Patrik
>>>
>>> On Sat, Oct 18, 2014 at 8:58 PM, Richard Rodseth <rrod...@gmail.com
>>> <javascript:>> wrote:
>>>
>>>> I have a simple test of Akka persistence with LevelDB. First app
>>>> creates 10000 aggregates, second app updates them, third app logs them
>>>> (via
>>>> a GetContent message). The good news is that the creation and updating
>>>> seems pretty snappy. In the logging (GetContent) app, I get the following
>>>> error (many times), but it does appear to complete the logging.
>>>>
>>>> [DEBUG] [10/18/2014 11:35:45.462]
>>>> [log-persistent-actors-test-akka.persistence.dispatchers.default-replay-dispatcher-34]
>>>>
>>>> [LocalActorRefProvider(akka://log-persistent-actors-test)] resolve of
>>>> unknown path [akka://create-persistent-actors-test/deadLetters] failed
>>>>
>>>> The only difference I see between the three scenarios is that in the
>>>> first two cases a persist() call happens. Is this error benign, or should
>>>> I
>>>> be sending a recover message before interacting normally with a persistent
>>>> actor?
>>>>
>>>> Each app looks like this:
>>>>
>>>> >>>
>>>>
>>>> object LogPersistentActors extends App {
>>>>
>>>> println("Log persistent actors app")
>>>>
>>>> implicit val system = ActorSystem("log-persistent-actors-test")
>>>>
>>>> val supervisor = system
>>>> .actorOf(SamplePersistentActorSupervisor.props)
>>>>
>>>> for (i <- 1 to 10000) {
>>>>
>>>> val id = s"id-$i"
>>>>
>>>> supervisor ! SamplePersistentActorSupervisor.GetContent(id)
>>>>
>>>> }
>>>>
>>>> }
>>>>
>>>> <<<
>>>>
>>>> The parent aggregate manager is doing this:
>>>>
>>>> >>>>
>>>>
>>>> override def receive: Receive = {
>>>>
>>>> case SamplePersistentActorSupervisor.CreateAggregate(id, content)
>>>> => {
>>>>
>>>> processAggregateCommand(id, SamplePersistentActor.Initialize(
>>>> content))
>>>>
>>>> }
>>>>
>>>> case SamplePersistentActorSupervisor.UpdateContent(id, content) =>
>>>> {
>>>>
>>>> processAggregateCommand(id, SamplePersistentActor.ChangeContent(
>>>> content))
>>>>
>>>> }
>>>>
>>>> case SamplePersistentActorSupervisor.GetContent(id) => {
>>>>
>>>> processAggregateCommand(id, SamplePersistentActor.GetContent)
>>>>
>>>> }
>>>>
>>>> }
>>>>
>>>> def processAggregateCommand(aggregateId: String, command:
>>>> SamplePersistentActor.Command) = {
>>>>
>>>> val maybeChild = context child aggregateId
>>>>
>>>> maybeChild match {
>>>>
>>>> case Some(child) => child forward command
>>>>
>>>> case None => {
>>>>
>>>> val child = createAggregate(aggregateId)
>>>>
>>>> child forward command
>>>>
>>>> }
>>>>
>>>> }
>>>>
>>>> }
>>>>
>>>>
>>>> private def createAggregate(id: String): ActorRef = {
>>>>
>>>> context.actorOf(SamplePersistentActor.props(id))
>>>>
>>>> }
>>>>
>>>> <<<
>>>>
>>>> The persistent aggregates have the following:
>>>>
>>>> >>>
>>>>
>>>> def initial: Receive = {
>>>>
>>>> case SamplePersistentActor.GetContent => {
>>>>
>>>> val info = SamplePersistentActor.Info(id, model.content, model.
>>>> count)
>>>>
>>>> // sender() ! info
>>>>
>>>> log.info("GetContent: {}", info)
>>>>
>>>> }
>>>>
>>>> case SamplePersistentActor.Initialize(content) => {
>>>>
>>>> if (content != "")
>>>>
>>>> persist(SamplePersistentActor.AggregateAdded(content)) { evt =>
>>>>
>>>> model = model.updated(evt)
>>>>
>>>> context.become(created)
>>>>
>>>> log.info("New aggregate saved: {}",
>>>> SamplePersistentActor.Info(id, model.content, model.count))
>>>>
>>>> }
>>>>
>>>> }
>>>>
>>>> }
>>>>
>>>>
>>>> def created: Receive = {
>>>>
>>>> case SamplePersistentActor.GetContent => {
>>>>
>>>> val info = SamplePersistentActor.Info(id, model.content, model.
>>>> count)
>>>>
>>>> // sender() ! info
>>>>
>>>> log.info("GetContent: {}", info)
>>>>
>>>> }
>>>>
>>>> case SamplePersistentActor.ChangeContent(newContent) =>
>>>>
>>>> persist(SamplePersistentActor.ContentChanged(newContent)) { evt
>>>> =>
>>>>
>>>> model = model.updated(evt)
>>>>
>>>> val info = SamplePersistentActor.Info(id, model.content, model.
>>>> count)
>>>>
>>>> log.info("Aggregate changed: {}", info)
>>>>
>>>> }
>>>>
>>>> }
>>>>
>>>> <<<
>>>>
>>>>
>>>> --
>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/
>>>> >>>>>>>>>> Check the FAQ:
>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>> >>>>>>>>>> Search the archives:
>>>> https://groups.google.com/group/akka-user
>>>> ---
>>>> You received this message because you are subscribed to the Google
>>>> Groups "Akka User List" group.
>>>> To unsubscribe from this group and stop receiving emails from it, send
>>>> an email to akka-user+...@googlegroups.com <javascript:>.
>>>> To post to this group, send email to akka...@googlegroups.com
>>>> <javascript:>.
>>>> Visit this group at http://groups.google.com/group/akka-user.
>>>> For more options, visit https://groups.google.com/d/optout.
>>>>
>>>
>>>
>>>
>>> --
>>>
>>> Patrik Nordwall
>>> Typesafe <http://typesafe.com/> - Reactive apps on the JVM
>>> Twitter: @patriknw
>>>
>>> --
>>> >>>>>>>>>> Read the docs: http://akka.io/docs/
>>> >>>>>>>>>> Check the FAQ:
>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>> >>>>>>>>>> Search the archives:
>>> https://groups.google.com/group/akka-user
>>> ---
>>> You received this message because you are subscribed to the Google
>>> Groups "Akka User List" group.
>>> To unsubscribe from this group and stop receiving emails from it, send
>>> an email to akka-user+...@googlegroups.com <javascript:>.
>>> To post to this group, send email to akka...@googlegroups.com
>>> <javascript:>.
>>> Visit this group at http://groups.google.com/group/akka-user.
>>> For more options, visit https://groups.google.com/d/optout.
>>>
>>
>> --
>> >>>>>>>>>> Read the docs: http://akka.io/docs/
>> >>>>>>>>>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
>> ---
>> You received this message because you are subscribed to the Google Groups
>> "Akka User List" group.
>> To unsubscribe from this group and stop receiving emails from it, send an
>> email to akka-user+...@googlegroups.com <javascript:>.
>> To post to this group, send email to akka...@googlegroups.com
>> <javascript:>.
>> Visit this group at http://groups.google.com/group/akka-user.
>> For more options, visit https://groups.google.com/d/optout.
>>
>
>
>
> --
>
> Patrik Nordwall
> Typesafe <http://typesafe.com/> - Reactive apps on the JVM
> Twitter: @patriknw
>
>
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
