Open sfresurgam opened 3 years ago
Here is the linkis-appjoint-entrance linkis.properties
wds.linkis.server.restful.scan.packages=com.webank.wedatasphere.linkis.entrance.restful
wds.linkis.engine.application.name=hiveEngine
wds.linkis.enginemanager.application.name=hiveEngineManager
wds.linkis.query.application.name=cloud-publicservice
wds.linkis.console.config.application.name=cloud-publicservice
wds.linkis.engine.creation.wait.time.max=20m
wds.linkis.server.version=v1
#hadoop config dir
#hadoop.config.dir=/appcom/config/hadoop-config
wds.linkis.entrance.config.logPath=file:///opt/mxy/tmp/linkis
wds.linkis.resultSet.store.path=hdfs:///data/result
wds.linkis.server.socket.mode=true
wds.linkis.entrance.job.persist.wait.max=10s
wds.dataworkis.appjoint.email.host=smtp.xx.cn
wds.dataworkis.appjoint.email.port=25
wds.dataworkis.appjoint.email.protocol=smtp
wds.dataworkis.appjoint.email.username=xxx@xxx.cn
wds.dataworkis.appjoint.email.password=xxxxxx
wds.dataworkis.appjoint.email.smtp.auth=true
wds.dataworkis.appjoint.email.smtp.starttls.enable=true
wds.dataworkis.appjoint.email.smtp.starttls.required=true
wds.dataworkis.appjoint.email.smtp.ssl.enable=false
wds.dataworkis.appjoint.email.smtp.timeout=25000
Please refer to Question 6 of the FAQ wiki page:https://github.com/WeBankFinTech/DataSphereStudio/wiki/FAQ_for_Usage
Please refer to Question 6 of the FAQ wiki page:https://github.com/WeBankFinTech/DataSphereStudio/wiki/FAQ_for_Usage
dss-appjoints contained 【sendemail appjoint】 and linkis.properties also set email-property 👆
linkis-appjoint-entrance log is here
why transition nodeexecution_hadoop_1 from Scheduler to Running failed. java.lang.NullPointerException: null
2021-03-17 17:42:28.176 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob 42 info - nodeexecution_hadoop_1 starts to run
2021-03-17 17:42:28.176 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob 42 info - nodeexecution_hadoop_1 change state Scheduled => Running.
2021-03-17 17:42:28.177 ERROR [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob 126 apply - transition nodeexecution_hadoop_1 from Scheduler to Running failed. java.lang.NullPointerException: null
at com.webank.wedatasphere.linkis.entrance.execute.EntranceJob.setEngineInstance$1(EntranceJob.scala:98) ~[linkis-ujes-entrance-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.entrance.execute.EntranceJob.afterStateChanged(EntranceJob.scala:104) ~[linkis-ujes-entrance-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.scheduler.queue.SchedulerEvent$class.transition(SchedulerEvent.scala:77) ~[linkis-scheduler-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.scheduler.queue.Job.transition(Job.scala:40) ~[linkis-scheduler-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$run$1.apply$mcV$sp(AppJointEntranceJob.scala:71) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$run$1.apply(AppJointEntranceJob.scala:71) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$run$1.apply(AppJointEntranceJob.scala:71) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryAndErrorMsg(Utils.scala:116) [linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob.run(AppJointEntranceJob.scala:71) [linkis-appjoint-entrance-0.9.0.jar:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_202]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_202]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
2021-03-17 17:42:28.178 INFO [appjointEntrance-EventListenerBus-Thread-0] com.webank.wedatasphere.linkis.entrance.EntranceWebSocketService 209 apply - retMessage: execID is 130815nodeexecutionappjointDSS-Server:9005nodeexecution_hadoop_1, status is Running, websocketTag is null
2021-03-17 17:42:28.183 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAwareLoadBalancer 112 chooseServer - Zone aware logic disabled or there is only one zone
2021-03-17 17:42:28.183 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.LoadBalancerContext 492 getServerFromLoadBalancer - dss-server using LB returned Server: DSS-Server:9004 for request http:///api/rest_j/v1/rpc/receiveAndReply
2021-03-17 17:42:28.197 WARN [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.appjoint.AppJointManager$ 61 apply - can not get application sendemail from dss-Server com.webank.wedatasphere.linkis.common.exception.ErrorException: errCode: 10001 ,desc: The transmitted bean is Null.(传输的bean为Null.) ,ip: DSS-Server ,port: 9004 ,serviceKind: dss-server
at com.webank.wedatasphere.linkis.common.exception.ExceptionManager.generateException(ExceptionManager.java:52) ~[linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.rpc.transform.RPCConsumer$$anon$1.toObject(RPCConsumer.scala:67) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender$$anonfun$ask$1.apply(BaseRPCSender.scala:87) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.execute(BaseRPCSender.scala:80) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.ask(BaseRPCSender.scala:83) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.appjoint.AppJointManager$$anonfun$1.apply(AppJointManager.scala:59) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.appjoint.AppJointManager$.getAppJoint(AppJointManager.scala:60) [linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointEntranceEngine.execute(AppJointEntranceEngine.scala:159) [linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob.run(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_202]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_202]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
2021-03-17 17:42:28.198 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.loader.CommonAppJointLoader 82 getAppJoint - classpathUrl is /opt/mxy/dss_linkis_new/dss/linkis-appjoint-entrance/conf/
2021-03-17 17:42:28.354 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.loader.CommonAppJointLoader 134 getAppJoint - appJointName is sendemail, retAppJoint is class com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailAppJoint
2021-03-17 17:42:28.445 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is category, V is node
2021-03-17 17:42:28.445 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is subject, V is test
2021-03-17 17:42:28.445 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is content, V is [d4900f79-5091-4272-9181-819efc87dcb9]
2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is to, V is maxiaoyu@luxin.cn
2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is cc, V is
2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is bcc, V is
2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is wds.linkis.schedulis.submit.user, V is hadoop
2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is workflow.shared.nodes.jobids, V is {hql=942}
2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is user, V is hadoop
2021-03-17 17:42:28.447 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is storePath, V is hdfs:///data/result/hadoop/dwc/20210317/nodeexecution/948
2021-03-17 17:42:28.456 INFO [Engine-Scheduler-ThreadPool-3] org.springframework.context.annotation.AnnotationConfigApplicationContext 87 log - Refreshing SpringClientFactory-cloud-publicserivce: startup date [Wed Mar 17 17:42:28 CST 2021]; parent: org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext@54da32dc
2021-03-17 17:42:28.490 INFO [Engine-Scheduler-ThreadPool-3] org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor 87 log - JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2021-03-17 17:42:28.571 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAffinityServerListFilter 83 initWithNiwsConfig - ZoneAffinity is set to true
2021-03-17 17:42:28.572 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAffinityServerListFilter 93 initWithNiwsConfig - activeReqeustsPerServerThreshold: 0.6
2021-03-17 17:42:28.572 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAffinityServerListFilter 95 initWithNiwsConfig - blackOutServerPercentageThreshold: 0.8
2021-03-17 17:42:28.573 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAffinityServerListFilter 97 initWithNiwsConfig - availableServersThreshold: 2
2021-03-17 17:42:28.578 INFO [Engine-Scheduler-ThreadPool-3] com.netflix.config.ChainedDynamicProperty 115 checkAndFlip - Flipping property: cloud-publicserivce.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
2021-03-17 17:42:28.586 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 319 setPingInterval - LoadBalancer [cloud-publicserivce]: pingIntervalSeconds set to 30
2021-03-17 17:42:28.586 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 337 setMaxTotalPingTime - LoadBalancer [cloud-publicserivce]: maxTotalPingTime set to 2
2021-03-17 17:42:28.587 INFO [Engine-Scheduler-ThreadPool-3] com.netflix.util.concurrent.ShutdownEnabledTimer 58 <init> - Shutdown hook installed for: NFLoadBalancer-PingTimer-cloud-publicserivce
2021-03-17 17:42:28.587 DEBUG [NFLoadBalancer-PingTimer-cloud-publicserivce] com.netflix.loadbalancer.BaseLoadBalancer 884 pingServers - LoadBalancer: PingTask executing [0] servers configured
2021-03-17 17:42:28.588 INFO [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 192 initWithConfig - Client: cloud-publicserivce instantiated a LoadBalancer: DynamicServerListLoadBalancer:{NFLoadBalancer:name=cloud-publicserivce,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:null
2021-03-17 17:42:28.589 INFO [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.DynamicServerListLoadBalancer 222 enableAndInitLearnNewServersFeature - Using serverListUpdater PollingServerListUpdater
2021-03-17 17:42:28.590 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.DynamicServerListLoadBalancer 241 updateListOfServers - List of Servers for cloud-publicserivce obtained from Discovery client: []
2021-03-17 17:42:28.590 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.DynamicServerListLoadBalancer 246 updateListOfServers - Filtered List of Servers for cloud-publicserivce obtained from Discovery client: []
2021-03-17 17:42:28.590 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 472 setServersList - LoadBalancer [cloud-publicserivce]: clearing server list (SET op)
2021-03-17 17:42:28.591 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.DynamicServerListLoadBalancer 179 setServerListForZones - Setting server list for zones: {}
2021-03-17 17:42:28.591 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 811 forceQuickPing - LoadBalancer [cloud-publicserivce]: forceQuickPing invoking
2021-03-17 17:42:28.591 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 884 pingServers - LoadBalancer: PingTask executing [0] servers configured
2021-03-17 17:42:28.592 INFO [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.DynamicServerListLoadBalancer 150 restOfInit - DynamicServerListLoadBalancer for client cloud-publicserivce initialized: DynamicServerListLoadBalancer:{NFLoadBalancer:name=cloud-publicserivce,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList@4eaf5287
2021-03-17 17:42:28.619 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAwareLoadBalancer 112 chooseServer - Zone aware logic disabled or there is only one zone
2021-03-17 17:42:28.623 ERROR [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution 78 putErrorMsg - failed to send email, 解析邮件内容失败! java.lang.RuntimeException: com.netflix.client.ClientException: Load balancer does not have available server for client: cloud-publicserivce
at org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient.execute(LoadBalancerFeignClient.java:71) ~[spring-cloud-openfeign-core-2.0.0.RELEASE.jar:2.0.0.RELEASE]
at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:97) ~[feign-core-9.5.0.jar:?]
at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:76) ~[feign-core-9.5.0.jar:?]
at feign.ReflectiveFeign$FeignInvocationHandler.invoke(ReflectiveFeign.java:103) ~[feign-core-9.5.0.jar:?]
at com.sun.proxy.$Proxy197.receiveAndReply(Unknown Source) ~[?:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender$$anonfun$ask$1.apply(BaseRPCSender.scala:86) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.execute(BaseRPCSender.scala:80) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.ask(BaseRPCSender.scala:83) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:83) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:82) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) ~[linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getJobById(AppJointNodeContextImpl.scala:105) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getResultSetPathsByJobId(AppJointNodeContextImpl.scala:227) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply$mcVJ$sp(MultiContentEmailGenerator.scala:46) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?]
at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) ~[scala-library-2.11.8.jar:?]
at scala.collection.mutable.ArrayOps$ofLong.foreach(ArrayOps.scala:246) ~[scala-library-2.11.8.jar:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmailContent(MultiContentEmailGenerator.scala:45) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.AbstractEmailGenerator$class.generateEmail(AbstractEmailGenerator.scala:37) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmail(MultiContentEmailGenerator.scala:32) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:52) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:50) ~[?:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution.execute(SendEmailNodeExecution.scala:61) [dss-sendmail-appjoint-core-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointEntranceEngine.execute(AppJointEntranceEngine.scala:173) [linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob.run(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_202]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_202]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
Caused by: com.netflix.client.ClientException: Load balancer does not have available server for client: cloud-publicserivce
at com.netflix.loadbalancer.LoadBalancerContext.getServerFromLoadBalancer(LoadBalancerContext.java:483) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5]
at com.netflix.loadbalancer.reactive.LoadBalancerCommand$1.call(LoadBalancerCommand.java:184) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5]
at com.netflix.loadbalancer.reactive.LoadBalancerCommand$1.call(LoadBalancerCommand.java:180) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5]
at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable.subscribe(Observable.java:8407) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable.subscribe(Observable.java:8374) ~[rxjava-1.1.1.jar:1.1.1]
at rx.observables.BlockingObservable.blockForSingle(BlockingObservable.java:433) ~[rxjava-1.1.1.jar:1.1.1]
at rx.observables.BlockingObservable.single(BlockingObservable.java:332) ~[rxjava-1.1.1.jar:1.1.1]
at com.netflix.client.AbstractLoadBalancerAwareClient.executeWithLoadBalancer(AbstractLoadBalancerAwareClient.java:112) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5]
at org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient.execute(LoadBalancerFeignClient.java:63) ~[spring-cloud-openfeign-core-2.0.0.RELEASE.jar:2.0.0.RELEASE]
... 34 more
2021-03-17 17:42:28.635 ERROR [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointEntranceEngine 177 execute - Failed Reason is 解析邮件内容失败! com.webank.wedatasphere.linkis.common.exception.ErrorException: errCode: 80079 ,desc: failed to sendEmail ,ip: DSS-Server ,port: 9005 ,serviceKind: appjointEntrance
at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution.putErrorMsg(SendEmailNodeExecution.scala:76) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$2.apply(SendEmailNodeExecution.scala:62) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$2.apply(SendEmailNodeExecution.scala:61) ~[?:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:54) ~[linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution.execute(SendEmailNodeExecution.scala:61) ~[?:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointEntranceEngine.execute(AppJointEntranceEngine.scala:173) [linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob.run(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_202]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_202]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
Caused by: java.lang.RuntimeException: com.netflix.client.ClientException: Load balancer does not have available server for client: cloud-publicserivce
at org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient.execute(LoadBalancerFeignClient.java:71) ~[spring-cloud-openfeign-core-2.0.0.RELEASE.jar:2.0.0.RELEASE]
at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:97) ~[feign-core-9.5.0.jar:?]
at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:76) ~[feign-core-9.5.0.jar:?]
at feign.ReflectiveFeign$FeignInvocationHandler.invoke(ReflectiveFeign.java:103) ~[feign-core-9.5.0.jar:?]
at com.sun.proxy.$Proxy197.receiveAndReply(Unknown Source) ~[?:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender$$anonfun$ask$1.apply(BaseRPCSender.scala:86) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.execute(BaseRPCSender.scala:80) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.ask(BaseRPCSender.scala:83) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:83) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:82) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) ~[linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getJobById(AppJointNodeContextImpl.scala:105) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getResultSetPathsByJobId(AppJointNodeContextImpl.scala:227) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply$mcVJ$sp(MultiContentEmailGenerator.scala:46) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?]
at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) ~[scala-library-2.11.8.jar:?]
at scala.collection.mutable.ArrayOps$ofLong.foreach(ArrayOps.scala:246) ~[scala-library-2.11.8.jar:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmailContent(MultiContentEmailGenerator.scala:45) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.AbstractEmailGenerator$class.generateEmail(AbstractEmailGenerator.scala:37) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmail(MultiContentEmailGenerator.scala:32) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:52) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:50) ~[?:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) ~[linkis-common-0.9.4.jar:?]
... 11 more
Caused by: com.netflix.client.ClientException: Load balancer does not have available server for client: cloud-publicserivce
at com.netflix.loadbalancer.LoadBalancerContext.getServerFromLoadBalancer(LoadBalancerContext.java:483) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5]
at com.netflix.loadbalancer.reactive.LoadBalancerCommand$1.call(LoadBalancerCommand.java:184) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5]
at com.netflix.loadbalancer.reactive.LoadBalancerCommand$1.call(LoadBalancerCommand.java:180) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5]
at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable.subscribe(Observable.java:8407) ~[rxjava-1.1.1.jar:1.1.1]
at rx.Observable.subscribe(Observable.java:8374) ~[rxjava-1.1.1.jar:1.1.1]
at rx.observables.BlockingObservable.blockForSingle(BlockingObservable.java:433) ~[rxjava-1.1.1.jar:1.1.1]
at rx.observables.BlockingObservable.single(BlockingObservable.java:332) ~[rxjava-1.1.1.jar:1.1.1]
at com.netflix.client.AbstractLoadBalancerAwareClient.executeWithLoadBalancer(AbstractLoadBalancerAwareClient.java:112) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5]
at org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient.execute(LoadBalancerFeignClient.java:63) ~[spring-cloud-openfeign-core-2.0.0.RELEASE.jar:2.0.0.RELEASE]
at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:97) ~[feign-core-9.5.0.jar:?]
at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:76) ~[feign-core-9.5.0.jar:?]
at feign.ReflectiveFeign$FeignInvocationHandler.invoke(ReflectiveFeign.java:103) ~[feign-core-9.5.0.jar:?]
at com.sun.proxy.$Proxy197.receiveAndReply(Unknown Source) ~[?:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender$$anonfun$ask$1.apply(BaseRPCSender.scala:86) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.execute(BaseRPCSender.scala:80) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.ask(BaseRPCSender.scala:83) ~[linkis-cloudRPC-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:83) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:82) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) ~[linkis-common-0.9.4.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getJobById(AppJointNodeContextImpl.scala:105) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getResultSetPathsByJobId(AppJointNodeContextImpl.scala:227) ~[linkis-appjoint-entrance-0.9.0.jar:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply$mcVJ$sp(MultiContentEmailGenerator.scala:46) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?]
at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) ~[scala-library-2.11.8.jar:?]
at scala.collection.mutable.ArrayOps$ofLong.foreach(ArrayOps.scala:246) ~[scala-library-2.11.8.jar:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmailContent(MultiContentEmailGenerator.scala:45) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.AbstractEmailGenerator$class.generateEmail(AbstractEmailGenerator.scala:37) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmail(MultiContentEmailGenerator.scala:32) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:52) ~[?:?]
at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:50) ~[?:?]
at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) ~[linkis-common-0.9.4.jar:?]
... 11 more
2021-03-17 17:42:28.667 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob 42 info - nodeexecution_hadoop_1 change state Running => Failed.
Please refer to Question 6 of the FAQ wiki page:https://github.com/WeBankFinTech/DataSphereStudio/wiki/FAQ_for_Usage
dss-appjoints contained 【sendemail appjoint】 and linkis.properties also set email-property 👆
linkis-appjoint-entrance log is here
why transition nodeexecution_hadoop_1 from Scheduler to Running failed. java.lang.NullPointerException: null
2021-03-17 17:42:28.176 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob 42 info - nodeexecution_hadoop_1 starts to run 2021-03-17 17:42:28.176 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob 42 info - nodeexecution_hadoop_1 change state Scheduled => Running. 2021-03-17 17:42:28.177 ERROR [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob 126 apply - transition nodeexecution_hadoop_1 from Scheduler to Running failed. java.lang.NullPointerException: null at com.webank.wedatasphere.linkis.entrance.execute.EntranceJob.setEngineInstance$1(EntranceJob.scala:98) ~[linkis-ujes-entrance-0.9.4.jar:?] at com.webank.wedatasphere.linkis.entrance.execute.EntranceJob.afterStateChanged(EntranceJob.scala:104) ~[linkis-ujes-entrance-0.9.4.jar:?] at com.webank.wedatasphere.linkis.scheduler.queue.SchedulerEvent$class.transition(SchedulerEvent.scala:77) ~[linkis-scheduler-0.9.4.jar:?] at com.webank.wedatasphere.linkis.scheduler.queue.Job.transition(Job.scala:40) ~[linkis-scheduler-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$run$1.apply$mcV$sp(AppJointEntranceJob.scala:71) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$run$1.apply(AppJointEntranceJob.scala:71) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$run$1.apply(AppJointEntranceJob.scala:71) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryAndErrorMsg(Utils.scala:116) [linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob.run(AppJointEntranceJob.scala:71) [linkis-appjoint-entrance-0.9.0.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_202] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_202] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_202] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202] 2021-03-17 17:42:28.178 INFO [appjointEntrance-EventListenerBus-Thread-0] com.webank.wedatasphere.linkis.entrance.EntranceWebSocketService 209 apply - retMessage: execID is 130815nodeexecutionappjointDSS-Server:9005nodeexecution_hadoop_1, status is Running, websocketTag is null 2021-03-17 17:42:28.183 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAwareLoadBalancer 112 chooseServer - Zone aware logic disabled or there is only one zone 2021-03-17 17:42:28.183 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.LoadBalancerContext 492 getServerFromLoadBalancer - dss-server using LB returned Server: DSS-Server:9004 for request http:///api/rest_j/v1/rpc/receiveAndReply 2021-03-17 17:42:28.197 WARN [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.appjoint.AppJointManager$ 61 apply - can not get application sendemail from dss-Server com.webank.wedatasphere.linkis.common.exception.ErrorException: errCode: 10001 ,desc: The transmitted bean is Null.(传输的bean为Null.) ,ip: DSS-Server ,port: 9004 ,serviceKind: dss-server at com.webank.wedatasphere.linkis.common.exception.ExceptionManager.generateException(ExceptionManager.java:52) ~[linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.linkis.rpc.transform.RPCConsumer$$anon$1.toObject(RPCConsumer.scala:67) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender$$anonfun$ask$1.apply(BaseRPCSender.scala:87) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.execute(BaseRPCSender.scala:80) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.ask(BaseRPCSender.scala:83) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.appjoint.AppJointManager$$anonfun$1.apply(AppJointManager.scala:59) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.appjoint.AppJointManager$.getAppJoint(AppJointManager.scala:60) [linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointEntranceEngine.execute(AppJointEntranceEngine.scala:159) [linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob.run(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_202] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_202] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_202] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202] 2021-03-17 17:42:28.198 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.loader.CommonAppJointLoader 82 getAppJoint - classpathUrl is /opt/mxy/dss_linkis_new/dss/linkis-appjoint-entrance/conf/ 2021-03-17 17:42:28.354 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.loader.CommonAppJointLoader 134 getAppJoint - appJointName is sendemail, retAppJoint is class com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailAppJoint 2021-03-17 17:42:28.445 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is category, V is node 2021-03-17 17:42:28.445 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is subject, V is test 2021-03-17 17:42:28.445 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is content, V is [d4900f79-5091-4272-9181-819efc87dcb9] 2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is to, V is maxiaoyu@luxin.cn 2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is cc, V is 2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is bcc, V is 2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is wds.linkis.schedulis.submit.user, V is hadoop 2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is workflow.shared.nodes.jobids, V is {hql=942} 2021-03-17 17:42:28.446 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is user, V is hadoop 2021-03-17 17:42:28.447 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator 44 apply - K is storePath, V is hdfs:///data/result/hadoop/dwc/20210317/nodeexecution/948 2021-03-17 17:42:28.456 INFO [Engine-Scheduler-ThreadPool-3] org.springframework.context.annotation.AnnotationConfigApplicationContext 87 log - Refreshing SpringClientFactory-cloud-publicserivce: startup date [Wed Mar 17 17:42:28 CST 2021]; parent: org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext@54da32dc 2021-03-17 17:42:28.490 INFO [Engine-Scheduler-ThreadPool-3] org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor 87 log - JSR-330 'javax.inject.Inject' annotation found and supported for autowiring 2021-03-17 17:42:28.571 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAffinityServerListFilter 83 initWithNiwsConfig - ZoneAffinity is set to true 2021-03-17 17:42:28.572 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAffinityServerListFilter 93 initWithNiwsConfig - activeReqeustsPerServerThreshold: 0.6 2021-03-17 17:42:28.572 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAffinityServerListFilter 95 initWithNiwsConfig - blackOutServerPercentageThreshold: 0.8 2021-03-17 17:42:28.573 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAffinityServerListFilter 97 initWithNiwsConfig - availableServersThreshold: 2 2021-03-17 17:42:28.578 INFO [Engine-Scheduler-ThreadPool-3] com.netflix.config.ChainedDynamicProperty 115 checkAndFlip - Flipping property: cloud-publicserivce.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647 2021-03-17 17:42:28.586 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 319 setPingInterval - LoadBalancer [cloud-publicserivce]: pingIntervalSeconds set to 30 2021-03-17 17:42:28.586 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 337 setMaxTotalPingTime - LoadBalancer [cloud-publicserivce]: maxTotalPingTime set to 2 2021-03-17 17:42:28.587 INFO [Engine-Scheduler-ThreadPool-3] com.netflix.util.concurrent.ShutdownEnabledTimer 58 <init> - Shutdown hook installed for: NFLoadBalancer-PingTimer-cloud-publicserivce 2021-03-17 17:42:28.587 DEBUG [NFLoadBalancer-PingTimer-cloud-publicserivce] com.netflix.loadbalancer.BaseLoadBalancer 884 pingServers - LoadBalancer: PingTask executing [0] servers configured 2021-03-17 17:42:28.588 INFO [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 192 initWithConfig - Client: cloud-publicserivce instantiated a LoadBalancer: DynamicServerListLoadBalancer:{NFLoadBalancer:name=cloud-publicserivce,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:null 2021-03-17 17:42:28.589 INFO [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.DynamicServerListLoadBalancer 222 enableAndInitLearnNewServersFeature - Using serverListUpdater PollingServerListUpdater 2021-03-17 17:42:28.590 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.DynamicServerListLoadBalancer 241 updateListOfServers - List of Servers for cloud-publicserivce obtained from Discovery client: [] 2021-03-17 17:42:28.590 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.DynamicServerListLoadBalancer 246 updateListOfServers - Filtered List of Servers for cloud-publicserivce obtained from Discovery client: [] 2021-03-17 17:42:28.590 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 472 setServersList - LoadBalancer [cloud-publicserivce]: clearing server list (SET op) 2021-03-17 17:42:28.591 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.DynamicServerListLoadBalancer 179 setServerListForZones - Setting server list for zones: {} 2021-03-17 17:42:28.591 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 811 forceQuickPing - LoadBalancer [cloud-publicserivce]: forceQuickPing invoking 2021-03-17 17:42:28.591 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.BaseLoadBalancer 884 pingServers - LoadBalancer: PingTask executing [0] servers configured 2021-03-17 17:42:28.592 INFO [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.DynamicServerListLoadBalancer 150 restOfInit - DynamicServerListLoadBalancer for client cloud-publicserivce initialized: DynamicServerListLoadBalancer:{NFLoadBalancer:name=cloud-publicserivce,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList@4eaf5287 2021-03-17 17:42:28.619 DEBUG [Engine-Scheduler-ThreadPool-3] com.netflix.loadbalancer.ZoneAwareLoadBalancer 112 chooseServer - Zone aware logic disabled or there is only one zone 2021-03-17 17:42:28.623 ERROR [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution 78 putErrorMsg - failed to send email, 解析邮件内容失败! java.lang.RuntimeException: com.netflix.client.ClientException: Load balancer does not have available server for client: cloud-publicserivce at org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient.execute(LoadBalancerFeignClient.java:71) ~[spring-cloud-openfeign-core-2.0.0.RELEASE.jar:2.0.0.RELEASE] at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:97) ~[feign-core-9.5.0.jar:?] at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:76) ~[feign-core-9.5.0.jar:?] at feign.ReflectiveFeign$FeignInvocationHandler.invoke(ReflectiveFeign.java:103) ~[feign-core-9.5.0.jar:?] at com.sun.proxy.$Proxy197.receiveAndReply(Unknown Source) ~[?:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender$$anonfun$ask$1.apply(BaseRPCSender.scala:86) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.execute(BaseRPCSender.scala:80) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.ask(BaseRPCSender.scala:83) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:83) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:82) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) ~[linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getJobById(AppJointNodeContextImpl.scala:105) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getResultSetPathsByJobId(AppJointNodeContextImpl.scala:227) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply$mcVJ$sp(MultiContentEmailGenerator.scala:46) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?] at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) ~[scala-library-2.11.8.jar:?] at scala.collection.mutable.ArrayOps$ofLong.foreach(ArrayOps.scala:246) ~[scala-library-2.11.8.jar:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmailContent(MultiContentEmailGenerator.scala:45) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.AbstractEmailGenerator$class.generateEmail(AbstractEmailGenerator.scala:37) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmail(MultiContentEmailGenerator.scala:32) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:52) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:50) ~[?:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution.execute(SendEmailNodeExecution.scala:61) [dss-sendmail-appjoint-core-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointEntranceEngine.execute(AppJointEntranceEngine.scala:173) [linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob.run(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_202] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_202] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_202] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202] Caused by: com.netflix.client.ClientException: Load balancer does not have available server for client: cloud-publicserivce at com.netflix.loadbalancer.LoadBalancerContext.getServerFromLoadBalancer(LoadBalancerContext.java:483) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5] at com.netflix.loadbalancer.reactive.LoadBalancerCommand$1.call(LoadBalancerCommand.java:184) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5] at com.netflix.loadbalancer.reactive.LoadBalancerCommand$1.call(LoadBalancerCommand.java:180) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5] at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable.subscribe(Observable.java:8407) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable.subscribe(Observable.java:8374) ~[rxjava-1.1.1.jar:1.1.1] at rx.observables.BlockingObservable.blockForSingle(BlockingObservable.java:433) ~[rxjava-1.1.1.jar:1.1.1] at rx.observables.BlockingObservable.single(BlockingObservable.java:332) ~[rxjava-1.1.1.jar:1.1.1] at com.netflix.client.AbstractLoadBalancerAwareClient.executeWithLoadBalancer(AbstractLoadBalancerAwareClient.java:112) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5] at org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient.execute(LoadBalancerFeignClient.java:63) ~[spring-cloud-openfeign-core-2.0.0.RELEASE.jar:2.0.0.RELEASE] ... 34 more 2021-03-17 17:42:28.635 ERROR [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointEntranceEngine 177 execute - Failed Reason is 解析邮件内容失败! com.webank.wedatasphere.linkis.common.exception.ErrorException: errCode: 80079 ,desc: failed to sendEmail ,ip: DSS-Server ,port: 9005 ,serviceKind: appjointEntrance at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution.putErrorMsg(SendEmailNodeExecution.scala:76) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$2.apply(SendEmailNodeExecution.scala:62) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$2.apply(SendEmailNodeExecution.scala:61) ~[?:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:54) ~[linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution.execute(SendEmailNodeExecution.scala:61) ~[?:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointEntranceEngine.execute(AppJointEntranceEngine.scala:173) [linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob$$anonfun$1.apply(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) [linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob.run(AppJointEntranceJob.scala:75) [linkis-appjoint-entrance-0.9.0.jar:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_202] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_202] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_202] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202] Caused by: java.lang.RuntimeException: com.netflix.client.ClientException: Load balancer does not have available server for client: cloud-publicserivce at org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient.execute(LoadBalancerFeignClient.java:71) ~[spring-cloud-openfeign-core-2.0.0.RELEASE.jar:2.0.0.RELEASE] at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:97) ~[feign-core-9.5.0.jar:?] at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:76) ~[feign-core-9.5.0.jar:?] at feign.ReflectiveFeign$FeignInvocationHandler.invoke(ReflectiveFeign.java:103) ~[feign-core-9.5.0.jar:?] at com.sun.proxy.$Proxy197.receiveAndReply(Unknown Source) ~[?:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender$$anonfun$ask$1.apply(BaseRPCSender.scala:86) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.execute(BaseRPCSender.scala:80) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.ask(BaseRPCSender.scala:83) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:83) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:82) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) ~[linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getJobById(AppJointNodeContextImpl.scala:105) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getResultSetPathsByJobId(AppJointNodeContextImpl.scala:227) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply$mcVJ$sp(MultiContentEmailGenerator.scala:46) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?] at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) ~[scala-library-2.11.8.jar:?] at scala.collection.mutable.ArrayOps$ofLong.foreach(ArrayOps.scala:246) ~[scala-library-2.11.8.jar:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmailContent(MultiContentEmailGenerator.scala:45) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.AbstractEmailGenerator$class.generateEmail(AbstractEmailGenerator.scala:37) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmail(MultiContentEmailGenerator.scala:32) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:52) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:50) ~[?:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) ~[linkis-common-0.9.4.jar:?] ... 11 more Caused by: com.netflix.client.ClientException: Load balancer does not have available server for client: cloud-publicserivce at com.netflix.loadbalancer.LoadBalancerContext.getServerFromLoadBalancer(LoadBalancerContext.java:483) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5] at com.netflix.loadbalancer.reactive.LoadBalancerCommand$1.call(LoadBalancerCommand.java:184) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5] at com.netflix.loadbalancer.reactive.LoadBalancerCommand$1.call(LoadBalancerCommand.java:180) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5] at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:162) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable$2.call(Observable.java:154) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable.subscribe(Observable.java:8407) ~[rxjava-1.1.1.jar:1.1.1] at rx.Observable.subscribe(Observable.java:8374) ~[rxjava-1.1.1.jar:1.1.1] at rx.observables.BlockingObservable.blockForSingle(BlockingObservable.java:433) ~[rxjava-1.1.1.jar:1.1.1] at rx.observables.BlockingObservable.single(BlockingObservable.java:332) ~[rxjava-1.1.1.jar:1.1.1] at com.netflix.client.AbstractLoadBalancerAwareClient.executeWithLoadBalancer(AbstractLoadBalancerAwareClient.java:112) ~[ribbon-loadbalancer-2.2.5.jar:2.2.5] at org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient.execute(LoadBalancerFeignClient.java:63) ~[spring-cloud-openfeign-core-2.0.0.RELEASE.jar:2.0.0.RELEASE] at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:97) ~[feign-core-9.5.0.jar:?] at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:76) ~[feign-core-9.5.0.jar:?] at feign.ReflectiveFeign$FeignInvocationHandler.invoke(ReflectiveFeign.java:103) ~[feign-core-9.5.0.jar:?] at com.sun.proxy.$Proxy197.receiveAndReply(Unknown Source) ~[?:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender$$anonfun$ask$1.apply(BaseRPCSender.scala:86) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.execute(BaseRPCSender.scala:80) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.linkis.rpc.BaseRPCSender.ask(BaseRPCSender.scala:83) ~[linkis-cloudRPC-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:83) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl$$anonfun$1.apply(AppJointNodeContextImpl.scala:82) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) ~[linkis-common-0.9.4.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getJobById(AppJointNodeContextImpl.scala:105) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.linkis.appjoint.entrance.execute.AppJointNodeContextImpl.getResultSetPathsByJobId(AppJointNodeContextImpl.scala:227) ~[linkis-appjoint-entrance-0.9.0.jar:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply$mcVJ$sp(MultiContentEmailGenerator.scala:46) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator$$anonfun$generateEmailContent$1.apply(MultiContentEmailGenerator.scala:45) ~[?:?] at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) ~[scala-library-2.11.8.jar:?] at scala.collection.mutable.ArrayOps$ofLong.foreach(ArrayOps.scala:246) ~[scala-library-2.11.8.jar:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmailContent(MultiContentEmailGenerator.scala:45) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.AbstractEmailGenerator$class.generateEmail(AbstractEmailGenerator.scala:37) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.email.generate.MultiContentEmailGenerator.generateEmail(MultiContentEmailGenerator.scala:32) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:52) ~[?:?] at com.webank.wedatasphere.dss.appjoint.sendemail.SendEmailNodeExecution$$anonfun$1.apply(SendEmailNodeExecution.scala:50) ~[?:?] at com.webank.wedatasphere.linkis.common.utils.Utils$.tryCatch(Utils.scala:48) ~[linkis-common-0.9.4.jar:?] ... 11 more 2021-03-17 17:42:28.667 INFO [Engine-Scheduler-ThreadPool-3] com.webank.wedatasphere.dss.linkis.appjoint.entrance.job.AppJointEntranceJob 42 info - nodeexecution_hadoop_1 change state Running => Failed.
Hello, I have the same problem as you. Have you solved it
Send Mail's type is node, the selected Node is Hql node, Hql works successful, But Mail Node forward to failure Here is the dss-server error message:
the workflow image console image