You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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)
The text was updated successfully, but these errors were encountered:
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)
The text was updated successfully, but these errors were encountered: