[Bug] An exception occurred during Agent distribution

chenxu8989 commented 1 year ago

Search before asking

[X] I had searched in the issues and found no similar issues.

What happened

datasophon-worker.tar.gz 已上传至 /opt/datasophon/DDP/packages 下

[INFO] 2023-05-05 16:51:49 com.datasophon.api.master.DispatcherWorkerActor:[49] - host actor restart because File not exist: /opt/datasophon/DDP/packages/datasophon-worker.tar.gz.md5
[ERROR] [05/05/2023 16:51:49.034] [datasophon-akka.actor.default-dispatcher-33] [akka://datasophon/user/dispatcherWorkerActor-ds-5] File not exist: /opt/datasophon/DDP/packages/datasophon-worker.tar.gz.md5
cn.hutool.core.io.IORuntimeException: File not exist: /opt/datasophon/DDP/packages/datasophon-worker.tar.gz.md5
        at cn.hutool.core.io.file.FileReader.checkFile(FileReader.java:300)
        at cn.hutool.core.io.file.FileReader.<init>(FileReader.java:57)
        at cn.hutool.core.io.file.FileReader.create(FileReader.java:37)
        at cn.hutool.core.io.FileUtil.readString(FileUtil.java:2083)
        at cn.hutool.core.io.FileUtil.readString(FileUtil.java:2109)
        at com.datasophon.api.master.handler.host.CheckWorkerMd5Handler.handle(CheckWorkerMd5Handler.java:42)
        at com.datasophon.api.master.handler.host.DispatcherWorkerHandlerChain.handle(DispatcherWorkerHandlerChain.java:38)
        at com.datasophon.api.master.DispatcherWorkerActor.onReceive(DispatcherWorkerActor.java:71)
        at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
        at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
        at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
        at akka.actor.ActorCell.invoke(ActorCell.scala:495)
        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
        at akka.dispatch.Mailbox.run(Mailbox.scala:224)
        at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
        at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
        at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
        at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
        at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

What you expected to happen

Agent分发时异常

How to reproduce

Agent分发时异常

Anything else

No response

Version

dev

Are you willing to submit PR?

[ ] Yes I am willing to submit a PR!

Code of Conduct

[X] I agree to follow this project's Code of Conduct

github-actions[bot] commented 1 year ago

Search before asking

[X] I had searched in the issues and found no similar issues.

What happened

datasophon-worker.tar.gz 已上传至 /opt/datasophon/DDP/packages 下

[INFO] 2023-05-05 16:51:49 com.datasophon.api.master.DispatcherWorkerActor:[49] - host actor restart because File not exist: /opt/datasophon/DDP/packages/datasophon-worker.tar.gz.md5
[ERROR] [05/05/2023 16:51:49.034] [datasophon-akka.actor.default-dispatcher-33] [akka://datasophon/user/dispatcherWorkerActor-ds-5] File not exist: /opt/datasophon/DDP/packages/datasophon-worker.tar.gz.md5
cn.hutool.core.io.IORuntimeException: File not exist: /opt/datasophon/DDP/packages/datasophon-worker.tar.gz.md5
        at cn.hutool.core.io.file.FileReader.checkFile(FileReader.java:300)
        at cn.hutool.core.io.file.FileReader.<init>(FileReader.java:57)
        at cn.hutool.core.io.file.FileReader.create(FileReader.java:37)
        at cn.hutool.core.io.FileUtil.readString(FileUtil.java:2083)
        at cn.hutool.core.io.FileUtil.readString(FileUtil.java:2109)
        at com.datasophon.api.master.handler.host.CheckWorkerMd5Handler.handle(CheckWorkerMd5Handler.java:42)
        at com.datasophon.api.master.handler.host.DispatcherWorkerHandlerChain.handle(DispatcherWorkerHandlerChain.java:38)
        at com.datasophon.api.master.DispatcherWorkerActor.onReceive(DispatcherWorkerActor.java:71)
        at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165)
        at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
        at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
        at akka.actor.ActorCell.invoke(ActorCell.scala:495)
        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
        at akka.dispatch.Mailbox.run(Mailbox.scala:224)
        at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
        at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
        at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
        at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
        at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

What you expected to happen

Agent分发时异常

How to reproduce

Agent分发时异常

Anything else

No response

Version

dev

Are you willing to submit PR?

[ ] Yes I am willing to submit a PR!

Code of Conduct

[X] I agree to follow this project's Code of Conduct

github-actions[bot] commented 1 year ago

Thank you for your feedback, we have received your issue, Please wait patiently for a reply.

In order for us to understand your request as soon as possible, please provide detailed information, version or pictures.

datasophon commented 1 year ago

you are not generate /opt/datasophon/DDP/packages/datasophon-worker.tar.gz.md5 file, use "java -jar file-md5-1.0-SNAPSHOT-jar-with-dependencies.jar" datasophon-worker.tar.gz to generate it.

datavane / datasophon