edp963 / wormhole

Wormhole is a SPaaS (Stream Processing as a Service) Platform
https://edp963.github.io/wormhole
Apache License 2.0
978 stars 481 forks source link

启动报错,什么原因啊 #1176

Open daydayup-zyn opened 4 years ago

daydayup-zyn commented 4 years ago

2020-02-26 10:25:43 [riderActorSystem-akka.actor.default-dispatcher-5] ERROR edp.rider.yarn.YarnStatusQuery[198] - query yarn resourceManager http://localhost:8088/ws/v1/cluster/info haState failed java.net.ConnectException: Connection refused (Connection refused) at java.net.PlainSocketImpl.socketConnect(Native Method) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) at java.net.Socket.connect(Socket.java:589) at sun.net.NetworkClient.doConnect(NetworkClient.java:175) at sun.net.www.http.HttpClient.openServer(HttpClient.java:463) at sun.net.www.http.HttpClient.openServer(HttpClient.java:558) at sun.net.www.http.HttpClient.(HttpClient.java:242) at sun.net.www.http.HttpClient.New(HttpClient.java:339) at sun.net.www.http.HttpClient.New(HttpClient.java:357) at sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1202) at sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1138) at sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1032) at sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:966) at scalaj.http.DefaultConnectFunc$.apply(Http.scala:471) at scalaj.http.DefaultConnectFunc$.apply(Http.scala:469) at scalaj.http.HttpRequest.scalaj$http$HttpRequest$$doConnection(Http.scala:355) at scalaj.http.HttpRequest.exec(Http.scala:335) at scalaj.http.HttpRequest.asString(Http.scala:455) at edp.rider.yarn.YarnStatusQuery$.getResourceManagerHaState(YarnStatusQuery.scala:190) at edp.rider.yarn.YarnStatusQuery$.getActiveResourceManager(YarnStatusQuery.scala:178) at edp.rider.yarn.YarnStatusQuery$.getFlinkJobStatusOnYarn(YarnStatusQuery.scala:212) at edp.rider.rest.util.FlowUtils$.getFlowStatusByYarn(FlowUtils.scala:1390) at edp.rider.rest.persistence.dal.FlowDal.updateFlowStatusByYarn(FlowDal.scala:46) at edp.rider.yarn.YarnStatusQuery$.updateStatusByYarn(YarnStatusQuery.scala:55) at edp.rider.schedule.ScheduledTask$.updateAllStatusByYarn(ScheduledTask.scala:68) at edp.rider.schedule.SchedulerActor$$anonfun$receive$1.applyOrElse(Scheduler.scala:35) at akka.actor.Actor$class.aroundReceive(Actor.scala:497) at edp.rider.schedule.SchedulerActor.aroundReceive(Scheduler.scala:27) 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)