2019-10-14 13:38:57.844 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 13:43:43.573 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.server.security.SSOUtils$ 42 info - add login userTicketCookie for user allwefantasy.
2019-10-14 13:43:43.634 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.parser.DefaultGatewayParser 42 info - /192.168.216.157:60192 try to heartbeat.
2019-10-14 13:43:43.669 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/execute
2019-10-14 13:43:43.669 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.ujes.parser.EntranceExecutionGatewayParser 42 info - GatewayParser parse requestUri /api/rest_j/v1/entrance/execute to service allwefantasy or mlsql.
2019-10-14 13:43:43.670 WARN [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 13:43:43.671 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/execute with parsedService mlsql to ServiceInstance(mlsqlentrance, null)
2019-10-14 13:43:44.618 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_3/status
2019-10-14 13:43:44.619 WARN [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 13:43:44.620 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_3/status with parsedService mlsql to ServiceInstance(mlsqlentrance, 192.168.216.157:8889)
2019-10-14 13:43:44,703 INFO (reactor-http-nio-8) INFO AnnotationConfigApplicationContext - Refreshing SpringClientFactory-192.168.216.157: startup date [Mon Oct 14 13:43:44 CST 2019]; parent: org.springframework.boot.web.reactive.context.AnnotationConfigReactiveWebServerApplicationContext@6a2eea2a
2019-10-14 13:43:44,925 INFO (reactor-http-nio-8) INFO AutowiredAnnotationBeanPostProcessor - JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-10-14 13:43:45.228 INFO [reactor-http-nio-8] com.netflix.config.ChainedDynamicProperty 115 checkAndFlip - Flipping property: 192.168.216.157.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
2019-10-14 13:43:45.255 INFO [reactor-http-nio-8] com.netflix.util.concurrent.ShutdownEnabledTimer 58 <init> - Shutdown hook installed for: NFLoadBalancer-PingTimer-192.168.216.157
2019-10-14 13:43:45.263 INFO [reactor-http-nio-8] com.netflix.loadbalancer.BaseLoadBalancer 192 initWithConfig - Client: 192.168.216.157 instantiated a LoadBalancer: DynamicServerListLoadBalancer:{NFLoadBalancer:name=192.168.216.157,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:null
2019-10-14 13:43:45.267 INFO [reactor-http-nio-8] com.netflix.loadbalancer.DynamicServerListLoadBalancer 222 enableAndInitLearnNewServersFeature - Using serverListUpdater PollingServerListUpdater
2019-10-14 13:43:45.269 INFO [reactor-http-nio-8] com.netflix.loadbalancer.DynamicServerListLoadBalancer 150 restOfInit - DynamicServerListLoadBalancer for client 192.168.216.157 initialized: DynamicServerListLoadBalancer:{NFLoadBalancer:name=192.168.216.157,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList@6bce5331
2019-10-14 13:43:45,339 ERROR (reactor-http-nio-8) ERROR DefaultErrorWebExceptionHandler - Failed to handle request [GET http://192.168.216.157:8001/api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_3/status]
org.springframework.cloud.gateway.support.NotFoundException: Unable to find instance for 192.168.216.157
at org.springframework.cloud.gateway.filter.LoadBalancerClientFilter.filter(LoadBalancerClientFilter.java:72)
这个是网关的日志。可以看到，execute 成功的转发到了后端的mlsql entrance. 但是查看状态的(status)则提示找不到实例。
是需要哪里做配置么？比如gateway当前的配置如下：
application.yml:
server:
port: 8001
spring:
application:
name: DataWorkCloud-Gateway
cloud:
gateway:
routes:
- id: dws
uri: http://localhost:port/
predicates:
- Path=/dws/
- id: dws/vg
uri: http://localhost:port/
predicates:
- Path=/dws/vg/
- id: dws/easyide
uri: http://localhost:port/
predicates:
- Path=/dws/easyide/
eureka:
client:
serviceUrl:
defaultZone: http://127.0.0.1:20303/eureka/
registry-fetch-interval-seconds: 5
instance:
metadata-map:
linkis.properties:
wds.linkis.server.version=v1
wds.linkis.ldap.proxy.url=
wds.linkis.ldap.proxy.baseDN=
wds.linkis.server.restful.uri=/
wds.linkis.server.web.session.timeout=1h
wds.linkis.gateway.conf.enable.proxy.user=false
wds.linkis.gateway.conf.url.pass.auth=/dws/,/api/rest_j/v1/entrance/
wds.linkis.gateway.admin.user=allwefantasy
完整linkis.out 输出：
2019-10-14 12:42:58,492 INFO (background-preinit) INFO Version - HV000001: Hibernate Validator 5.1.2.Final
2019-10-14 12:42:59,240 INFO (main) INFO AnnotationConfigApplicationContext - Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@62e70ea3: startup date [Mon Oct 14 12:42:59 CST 2019]; root of context hierarchy
2019-10-14 12:42:59,601 INFO (main) INFO AutowiredAnnotationBeanPostProcessor - JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-10-14 12:42:59,650 INFO (main) INFO PostProcessorRegistrationDelegate$BeanPostProcessorChecker - Bean 'configurationPropertiesRebinderAutoConfiguration' of type [org.springframework.cloud.autoconfigure.ConfigurationPropertiesRebinderAutoConfiguration$$EnhancerBySpringCGLIB$$c4695e36] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v2.0.3.RELEASE)
2019-10-14 12:43:00,027 INFO (main) INFO ConfigServicePropertySourceLocator - Fetching config from server at : http://localhost:8888
2019-10-14 12:43:00,184 INFO (main) INFO ConfigServicePropertySourceLocator - Connect Timeout Exception on Url - http://localhost:8888. Will be trying the next url if available
2019-10-14 12:43:00,184 WARN (main) WARN ConfigServicePropertySourceLocator - Could not locate PropertySource: I/O error on GET request for "http://localhost:8888/DataWorkCloud-Gateway/default": Connection refused (Connection refused); nested exception is java.net.ConnectException: Connection refused (Connection refused)
2019-10-14 12:43:00,187 INFO (main) INFO DataWorkCloudApplication - No active profile set, falling back to default profiles: default
2019-10-14 12:43:00,215 INFO (main) INFO DataWorkCloudApplication - add config from config server...
2019-10-14 12:43:00,216 INFO (main) INFO DataWorkCloudApplication - initialize DataWorkCloud spring application...
2019-10-14 12:43:00,220 INFO (main) INFO AnnotationConfigReactiveWebServerApplicationContext - Refreshing org.springframework.boot.web.reactive.context.AnnotationConfigReactiveWebServerApplicationContext@6a2eea2a: startup date [Mon Oct 14 12:43:00 CST 2019]; parent: org.springframework.context.annotation.AnnotationConfigApplicationContext@62e70ea3
2019-10-14 12:43:02,088 INFO (main) INFO GenericScope - BeanFactory id=69a535b6-ab65-3029-9625-a81b105a5224
2019-10-14 12:43:02,147 INFO (main) INFO AutowiredAnnotationBeanPostProcessor - JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-10-14 12:43:02,639 INFO (main) INFO PostProcessorRegistrationDelegate$BeanPostProcessorChecker - Bean 'org.springframework.cloud.autoconfigure.ConfigurationPropertiesRebinderAutoConfiguration' of type [org.springframework.cloud.autoconfigure.ConfigurationPropertiesRebinderAutoConfiguration$$EnhancerBySpringCGLIB$$c4695e36] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
2019-10-14 12:43:03,211 INFO (main) INFO SimpleUrlHandlerMapping - Mapped URL path [/webjars/**] onto handler of type [class org.springframework.web.reactive.resource.ResourceWebHandler]
2019-10-14 12:43:03,211 INFO (main) INFO SimpleUrlHandlerMapping - Mapped URL path [/**] onto handler of type [class org.springframework.web.reactive.resource.ResourceWebHandler]
2019-10-14 12:43:04,976 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [After]
2019-10-14 12:43:04,976 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [Before]
2019-10-14 12:43:04,976 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [Between]
2019-10-14 12:43:04,977 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [Cookie]
2019-10-14 12:43:04,977 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [Header]
2019-10-14 12:43:04,977 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [Host]
2019-10-14 12:43:04,977 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [Method]
2019-10-14 12:43:04,977 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [Path]
2019-10-14 12:43:04,977 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [Query]
2019-10-14 12:43:04,977 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [ReadBodyPredicateFactory]
2019-10-14 12:43:04,977 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [RemoteAddr]
2019-10-14 12:43:04,977 INFO (main) INFO RouteDefinitionRouteLocator - Loaded RoutePredicateFactory [Weight]
2019-10-14 12:43:06.140 WARN [main] com.netflix.config.sources.URLConfigurationSource 121 <init> - No URLs will be polled as dynamic configuration sources.
2019-10-14 12:43:06.150 INFO [main] com.netflix.config.sources.URLConfigurationSource 122 <init> - To enable URLs as dynamic configuration sources, define System property archaius.configurationSource.additionalUrls or make config.properties available on classpath.
2019-10-14 12:43:06.185 INFO [main] com.netflix.config.DynamicPropertyFactory 281 getInstance - DynamicPropertyFactory is initialized with configuration sources: com.netflix.config.ConcurrentCompositeConfiguration@49bb808f
2019-10-14 12:43:06,703 INFO (main) INFO EndpointLinksResolver - Exposing 2 endpoint(s) beneath base path '/actuator'
2019-10-14 12:43:06,737 INFO (main) INFO WebFluxEndpointHandlerMapping - Mapped "{[/actuator/info],methods=[GET],produces=[application/vnd.spring-boot.actuator.v2+json || application/json]}" onto public org.reactivestreams.Publisher<org.springframework.http.ResponseEntity<java.lang.Object>> org.springframework.boot.actuate.endpoint.web.reactive.AbstractWebFluxEndpointHandlerMapping$ReadOperationHandler.handle(org.springframework.web.server.ServerWebExchange)
2019-10-14 12:43:06,739 INFO (main) INFO WebFluxEndpointHandlerMapping - Mapped "{[/actuator/refresh],methods=[POST],produces=[application/vnd.spring-boot.actuator.v2+json || application/json]}" onto public org.reactivestreams.Publisher<org.springframework.http.ResponseEntity<java.lang.Object>> org.springframework.boot.actuate.endpoint.web.reactive.AbstractWebFluxEndpointHandlerMapping$WriteOperationHandler.handle(org.springframework.web.server.ServerWebExchange,java.util.Map<java.lang.String, java.lang.String>)
2019-10-14 12:43:06,741 INFO (main) INFO WebFluxEndpointHandlerMapping - Mapped "{[/actuator],methods=[GET],produces=[application/vnd.spring-boot.actuator.v2+json || application/json]}" onto protected java.util.Map<java.lang.String, java.util.Map<java.lang.String, org.springframework.boot.actuate.endpoint.web.Link>> org.springframework.boot.actuate.endpoint.web.reactive.WebFluxEndpointHandlerMapping.links(org.springframework.web.server.ServerWebExchange)
2019-10-14 12:43:06,875 INFO (main) INFO ControllerMethodResolver - Looking for @ControllerAdvice: org.springframework.boot.web.reactive.context.AnnotationConfigReactiveWebServerApplicationContext@6a2eea2a: startup date [Mon Oct 14 12:43:00 CST 2019]; parent: org.springframework.context.annotation.AnnotationConfigApplicationContext@62e70ea3
2019-10-14 12:43:07,121 INFO (main) INFO CglibAopProxy - Final method [protected final void org.springframework.boot.web.servlet.support.SpringBootServletInitializer.setRegisterErrorPageFilter(boolean)] cannot get proxied via CGLIB: Calls to this method will NOT be routed to the target instance and might lead to NPEs against uninitialized fields in the proxy instance.
2019-10-14 12:43:07.154 INFO [main] com.webank.wedatasphere.linkis.rpc.RPCReceiveRestful 42 info - init all receiverChoosers in spring beans, list => List(com.webank.wedatasphere.linkis.rpc.CommonReceiverChooser@7ebc5be6)
2019-10-14 12:43:07.161 INFO [main] com.webank.wedatasphere.linkis.rpc.RPCReceiveRestful 42 info - init all receiverSenderBuilders in spring beans, list => List(com.webank.wedatasphere.linkis.rpc.CommonReceiverSenderBuilder@396f2724)
2019-10-14 12:43:07.172 INFO [main] com.webank.wedatasphere.linkis.rpc.RPCReceiveRestful 42 info - init RPCReceiverListenerBus with queueSize 1000 and consumeThreadSize 10.
2019-10-14 12:43:07.175 INFO [main] com.webank.wedatasphere.linkis.rpc.AsynRPCMessageBus 42 info - RPC-Receiver-Asyn-Thread-ListenerBus add a new listener => class com.webank.wedatasphere.linkis.rpc.RPCReceiveRestful$$anon$1
2019-10-14 12:43:07,287 INFO (main) INFO InstanceInfoFactory - Setting initial instance status as: STARTING
2019-10-14 12:43:07.375 INFO [main] com.netflix.discovery.DiscoveryClient 349 <init> - Initializing Eureka in region us-east-1
2019-10-14 12:43:07.507 INFO [main] com.netflix.discovery.provider.DiscoveryJerseyProvider 70 <init> - Using JSON encoding codec LegacyJacksonJson
2019-10-14 12:43:07.507 INFO [main] com.netflix.discovery.provider.DiscoveryJerseyProvider 71 <init> - Using JSON decoding codec LegacyJacksonJson
2019-10-14 12:43:07.732 INFO [main] com.netflix.discovery.provider.DiscoveryJerseyProvider 80 <init> - Using XML encoding codec XStreamXml
2019-10-14 12:43:07.732 INFO [main] com.netflix.discovery.provider.DiscoveryJerseyProvider 81 <init> - Using XML decoding codec XStreamXml
2019-10-14 12:43:08.156 INFO [main] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 12:43:08.206 INFO [main] com.netflix.discovery.DiscoveryClient 958 fetchRegistry - Disable delta property : false
2019-10-14 12:43:08.207 INFO [main] com.netflix.discovery.DiscoveryClient 959 fetchRegistry - Single vip registry refresh property : null
2019-10-14 12:43:08.207 INFO [main] com.netflix.discovery.DiscoveryClient 960 fetchRegistry - Force full registry fetch : false
2019-10-14 12:43:08.208 INFO [main] com.netflix.discovery.DiscoveryClient 961 fetchRegistry - Application is null : false
2019-10-14 12:43:08.208 INFO [main] com.netflix.discovery.DiscoveryClient 962 fetchRegistry - Registered Applications size is zero : true
2019-10-14 12:43:08.208 INFO [main] com.netflix.discovery.DiscoveryClient 964 fetchRegistry - Application version is -1: true
2019-10-14 12:43:08.209 INFO [main] com.netflix.discovery.DiscoveryClient 1047 getAndStoreFullRegistry - Getting all instance registry info from the eureka server
2019-10-14 12:43:08.756 INFO [main] com.netflix.discovery.DiscoveryClient 1056 getAndStoreFullRegistry - The response status is 200
2019-10-14 12:43:08.760 INFO [main] com.netflix.discovery.DiscoveryClient 1264 initScheduledTasks - Starting heartbeat executor: renew interval is: 30
2019-10-14 12:43:08.765 INFO [main] com.netflix.discovery.InstanceInfoReplicator 60 <init> - InstanceInfoReplicator onDemand update allowed rate per min is 4
2019-10-14 12:43:08.770 INFO [main] com.netflix.discovery.DiscoveryClient 449 <init> - Discovery Client initialized at timestamp 1571028188769 with initial instances count: 0
2019-10-14 12:43:09.158 WARN [main] com.netflix.config.sources.URLConfigurationSource 121 <init> - No URLs will be polled as dynamic configuration sources.
2019-10-14 12:43:09.159 INFO [main] com.netflix.config.sources.URLConfigurationSource 122 <init> - To enable URLs as dynamic configuration sources, define System property archaius.configurationSource.additionalUrls or make config.properties available on classpath.
2019-10-14 12:43:10,365 WARN (main) WARN EurekaStarterDeprecationWarningAutoConfiguration - spring-cloud-starter-eureka is deprecated as of Spring Cloud Netflix 1.4.0, please migrate to spring-cloud-starter-netflix-eureka
2019-10-14 12:43:10,483 INFO (main) INFO AnnotationMBeanExporter - Registering beans for JMX exposure on startup
2019-10-14 12:43:10,498 INFO (main) INFO AnnotationMBeanExporter - Bean with name 'refreshScope' has been autodetected for JMX exposure
2019-10-14 12:43:10,505 INFO (main) INFO AnnotationMBeanExporter - Bean with name 'environmentManager' has been autodetected for JMX exposure
2019-10-14 12:43:10,511 INFO (main) INFO AnnotationMBeanExporter - Bean with name 'configurationPropertiesRebinder' has been autodetected for JMX exposure
2019-10-14 12:43:10,517 INFO (main) INFO AnnotationMBeanExporter - Located managed bean 'environmentManager': registering with JMX server as MBean [org.springframework.cloud.context.environment:name=environmentManager,type=EnvironmentManager]
2019-10-14 12:43:10,536 INFO (main) INFO AnnotationMBeanExporter - Located managed bean 'refreshScope': registering with JMX server as MBean [org.springframework.cloud.context.scope.refresh:name=refreshScope,type=RefreshScope]
2019-10-14 12:43:10,564 INFO (main) INFO AnnotationMBeanExporter - Located managed bean 'configurationPropertiesRebinder': registering with JMX server as MBean [org.springframework.cloud.context.properties:name=configurationPropertiesRebinder,context=6a2eea2a,type=ConfigurationPropertiesRebinder]
2019-10-14 12:43:10,582 INFO (main) INFO DefaultLifecycleProcessor - Starting beans in phase 0
2019-10-14 12:43:10,584 INFO (main) INFO EurekaServiceRegistry - Registering application DataWorkCloud-Gateway with eureka with status UP
2019-10-14 12:43:10.585 INFO [main] com.netflix.discovery.DiscoveryClient 1299 notify - Saw local status change event StatusChangeEvent [timestamp=1571028190585, current=UP, previous=STARTING]
2019-10-14 12:43:10.590 INFO [DiscoveryClient-InstanceInfoReplicator-0] com.netflix.discovery.DiscoveryClient 826 register - DiscoveryClient_DATAWORKCLOUD-GATEWAY/192.168.216.157:DataWorkCloud-Gateway:8001: registering service...
2019-10-14 12:43:10.605 INFO [main] com.webank.wedatasphere.linkis.rpc.conf.RPCSpringConfiguration$$EnhancerBySpringCGLIB$$8656ecb 42 info - DataWorkCloud RPC need register RPCReceiveRestful, now add it to configuration.
2019-10-14 12:43:10,606 INFO (main) INFO DataWorkCloudApplication - add config from config server...
2019-10-14 12:43:10,606 INFO (main) INFO DataWorkCloudApplication - initialize DataWorkCloud spring application...
2019-10-14 12:43:10.793 INFO [DiscoveryClient-InstanceInfoReplicator-0] com.netflix.discovery.DiscoveryClient 835 register - DiscoveryClient_DATAWORKCLOUD-GATEWAY/192.168.216.157:DataWorkCloud-Gateway:8001 - registration status: 204
2019-10-14 12:43:10.928 INFO [reactor-http-nio-1] reactor.ipc.netty.tcp.BlockingNettyContext 255 info - Started HttpServer on /0:0:0:0:0:0:0:0:8001
2019-10-14 12:43:10,946 INFO (main) INFO NettyWebServer - Netty started on port(s): 8001
2019-10-14 12:43:10,955 INFO (main) INFO EurekaAutoServiceRegistration - Updating port to 8001
2019-10-14 12:43:10,971 INFO (main) INFO DataWorkCloudApplication - Started DataWorkCloudApplication in 13.298 seconds (JVM running for 14.733)
2019-10-14 12:43:13.763 INFO [DiscoveryClient-CacheRefreshExecutor-0] com.netflix.discovery.DiscoveryClient 958 fetchRegistry - Disable delta property : false
2019-10-14 12:43:13.764 INFO [DiscoveryClient-CacheRefreshExecutor-0] com.netflix.discovery.DiscoveryClient 959 fetchRegistry - Single vip registry refresh property : null
2019-10-14 12:43:13.764 INFO [DiscoveryClient-CacheRefreshExecutor-0] com.netflix.discovery.DiscoveryClient 960 fetchRegistry - Force full registry fetch : false
2019-10-14 12:43:13.764 INFO [DiscoveryClient-CacheRefreshExecutor-0] com.netflix.discovery.DiscoveryClient 961 fetchRegistry - Application is null : false
2019-10-14 12:43:13.764 INFO [DiscoveryClient-CacheRefreshExecutor-0] com.netflix.discovery.DiscoveryClient 962 fetchRegistry - Registered Applications size is zero : true
2019-10-14 12:43:13.765 INFO [DiscoveryClient-CacheRefreshExecutor-0] com.netflix.discovery.DiscoveryClient 964 fetchRegistry - Application version is -1: false
2019-10-14 12:43:13.765 INFO [DiscoveryClient-CacheRefreshExecutor-0] com.netflix.discovery.DiscoveryClient 1047 getAndStoreFullRegistry - Getting all instance registry info from the eureka server
2019-10-14 12:43:13.812 INFO [DiscoveryClient-CacheRefreshExecutor-0] com.netflix.discovery.DiscoveryClient 1056 getAndStoreFullRegistry - The response status is 200
2019-10-14 12:45:15.228 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.server.security.SSOUtils$ 42 info - add login userTicketCookie for user allwefantasy.
2019-10-14 12:45:15.416 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.parser.DefaultGatewayParser 42 info - /127.0.0.1:59470 try to heartbeat.
2019-10-14 12:45:15.467 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/execute
2019-10-14 12:45:15.471 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.ujes.parser.EntranceExecutionGatewayParser 42 info - GatewayParser parse requestUri /api/rest_j/v1/entrance/execute to service allwefantasy or mlsql.
2019-10-14 12:45:15.482 WARN [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 12:45:15.520 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/execute with parsedService mlsql to ServiceInstance(mlsqlentrance, null)
2019-10-14 12:45:15,529 INFO (reactor-http-nio-2) INFO AnnotationConfigApplicationContext - Refreshing SpringClientFactory-mlsqlentrance: startup date [Mon Oct 14 12:45:15 CST 2019]; parent: org.springframework.boot.web.reactive.context.AnnotationConfigReactiveWebServerApplicationContext@6a2eea2a
2019-10-14 12:45:15,595 INFO (reactor-http-nio-2) INFO AutowiredAnnotationBeanPostProcessor - JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-10-14 12:45:15.848 INFO [reactor-http-nio-2] com.netflix.config.ChainedDynamicProperty 115 checkAndFlip - Flipping property: mlsqlentrance.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
2019-10-14 12:45:15.874 INFO [reactor-http-nio-2] com.netflix.util.concurrent.ShutdownEnabledTimer 58 <init> - Shutdown hook installed for: NFLoadBalancer-PingTimer-mlsqlentrance
2019-10-14 12:45:15.881 INFO [reactor-http-nio-2] com.netflix.loadbalancer.BaseLoadBalancer 192 initWithConfig - Client: mlsqlentrance instantiated a LoadBalancer: DynamicServerListLoadBalancer:{NFLoadBalancer:name=mlsqlentrance,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:null
2019-10-14 12:45:15.889 INFO [reactor-http-nio-2] com.netflix.loadbalancer.DynamicServerListLoadBalancer 222 enableAndInitLearnNewServersFeature - Using serverListUpdater PollingServerListUpdater
2019-10-14 12:45:15.922 INFO [reactor-http-nio-2] com.netflix.config.ChainedDynamicProperty 115 checkAndFlip - Flipping property: mlsqlentrance.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
2019-10-14 12:45:15.925 INFO [reactor-http-nio-2] com.netflix.loadbalancer.DynamicServerListLoadBalancer 150 restOfInit - DynamicServerListLoadBalancer for client mlsqlentrance initialized: DynamicServerListLoadBalancer:{NFLoadBalancer:name=mlsqlentrance,current list of Servers=[192.168.216.157:8889],Load balancer stats=Zone stats: {defaultzone=[Zone:defaultzone; Instance count:1; Active connections count: 0; Circuit breaker tripped count: 0; Active connections per server: 0.0;]
},Server stats: [[Server:192.168.216.157:8889; Zone:defaultZone; Total Requests:0; Successive connection failure:0; Total blackout seconds:0; Last connection made:Thu Jan 01 08:00:00 CST 1970; First connection made: Thu Jan 01 08:00:00 CST 1970; Active Connections:0; total failure count in last (1000) msecs:0; average resp time:0.0; 90 percentile resp time:0.0; 95 percentile resp time:0.0; min resp time:0.0; max resp time:0.0; stddev resp time:0.0]
]}ServerList:org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList@68be0d55
2019-10-14 12:45:16.897 INFO [PollingServerListUpdater-0] com.netflix.config.ChainedDynamicProperty 115 checkAndFlip - Flipping property: mlsqlentrance.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
2019-10-14 12:45:20.498 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_0/status
2019-10-14 12:45:20.504 WARN [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 12:45:20.506 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_0/status with parsedService mlsql to ServiceInstance(mlsqlentrance, 192.168.216.157:8889)
2019-10-14 12:45:20,508 INFO (reactor-http-nio-2) INFO AnnotationConfigApplicationContext - Refreshing SpringClientFactory-127.0.0.1: startup date [Mon Oct 14 12:45:20 CST 2019]; parent: org.springframework.boot.web.reactive.context.AnnotationConfigReactiveWebServerApplicationContext@6a2eea2a
2019-10-14 12:45:20,549 INFO (reactor-http-nio-2) INFO AutowiredAnnotationBeanPostProcessor - JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-10-14 12:45:20.652 INFO [reactor-http-nio-2] com.netflix.config.ChainedDynamicProperty 115 checkAndFlip - Flipping property: 127.0.0.1.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
2019-10-14 12:45:20.661 INFO [reactor-http-nio-2] com.netflix.util.concurrent.ShutdownEnabledTimer 58 <init> - Shutdown hook installed for: NFLoadBalancer-PingTimer-127.0.0.1
2019-10-14 12:45:20.662 INFO [reactor-http-nio-2] com.netflix.loadbalancer.BaseLoadBalancer 192 initWithConfig - Client: 127.0.0.1 instantiated a LoadBalancer: DynamicServerListLoadBalancer:{NFLoadBalancer:name=127.0.0.1,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:null
2019-10-14 12:45:20.665 INFO [reactor-http-nio-2] com.netflix.loadbalancer.DynamicServerListLoadBalancer 222 enableAndInitLearnNewServersFeature - Using serverListUpdater PollingServerListUpdater
2019-10-14 12:45:20.666 INFO [reactor-http-nio-2] com.netflix.loadbalancer.DynamicServerListLoadBalancer 150 restOfInit - DynamicServerListLoadBalancer for client 127.0.0.1 initialized: DynamicServerListLoadBalancer:{NFLoadBalancer:name=127.0.0.1,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList@935c7d3
2019-10-14 12:45:20,716 ERROR (reactor-http-nio-2) ERROR DefaultErrorWebExceptionHandler - Failed to handle request [GET http://127.0.0.1:8001/api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_0/status]
org.springframework.cloud.gateway.support.NotFoundException: Unable to find instance for 127.0.0.1
at org.springframework.cloud.gateway.filter.LoadBalancerClientFilter.filter(LoadBalancerClientFilter.java:72)
at org.springframework.cloud.gateway.handler.FilteringWebHandler$GatewayFilterAdapter.filter(FilteringWebHandler.java:133)
at org.springframework.cloud.gateway.filter.OrderedGatewayFilter.filter(OrderedGatewayFilter.java:44)
at org.springframework.cloud.gateway.handler.FilteringWebHandler$DefaultGatewayFilterChain.lambda$filter$0(FilteringWebHandler.java:115)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:44)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:275)
at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:849)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.drain(FluxFilterWhen.java:266)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.onNext(FluxFilterWhen.java:134)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onNext(FluxDematerialize.java:114)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onNext(FluxDematerialize.java:42)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drainAsync(FluxFlattenIterable.java:395)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drain(FluxFlattenIterable.java:638)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onNext(FluxFlattenIterable.java:242)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:179)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1461)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.DrainUtils.postCompleteDrain(DrainUtils.java:131)
at reactor.core.publisher.DrainUtils.postComplete(DrainUtils.java:186)
at reactor.core.publisher.FluxMaterialize$MaterializeSubscriber.onComplete(FluxMaterialize.java:134)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drainAsync(FluxFlattenIterable.java:325)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drain(FluxFlattenIterable.java:638)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onComplete(FluxFlattenIterable.java:259)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1463)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:794)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:560)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:426)
at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:265)
at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:201)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:335)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
at reactor.core.publisher.FluxFlatMap.subscribe(FluxFlatMap.java:97)
at reactor.core.publisher.MonoCollectList.subscribe(MonoCollectList.java:59)
at reactor.core.publisher.MonoMapFuseable.subscribe(MonoMapFuseable.java:59)
at reactor.core.publisher.MonoFlattenIterable.subscribe(MonoFlattenIterable.java:101)
at reactor.core.publisher.FluxMaterialize.subscribe(FluxMaterialize.java:40)
at reactor.core.publisher.MonoCollectList.subscribe(MonoCollectList.java:59)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74)
at reactor.core.publisher.MonoFlattenIterable.subscribe(MonoFlattenIterable.java:101)
at reactor.core.publisher.FluxDematerialize.subscribe(FluxDematerialize.java:39)
at reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:54)
at reactor.core.publisher.FluxFilterWhen.subscribe(FluxFilterWhen.java:69)
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
at reactor.core.publisher.MonoMap.subscribe(MonoMap.java:55)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
at reactor.core.publisher.MonoMap.subscribe(MonoMap.java:55)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:442)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:212)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
at reactor.core.publisher.FluxConcatMap.subscribe(FluxConcatMap.java:121)
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
at reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:247)
at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:329)
at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2041)
at reactor.core.publisher.MonoZip$ZipInner.onSubscribe(MonoZip.java:318)
at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:128)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:70)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.ipc.netty.channel.ChannelOperations.applyHandler(ChannelOperations.java:380)
at reactor.ipc.netty.http.server.HttpServerOperations.onHandlerStart(HttpServerOperations.java:398)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:465)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884)
at java.lang.Thread.run(Thread.java:748)
2019-10-14 12:48:08.202 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 12:53:08.198 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 12:58:08.191 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 13:10:53.194 INFO [DiscoveryClient-HeartbeatExecutor-0] com.netflix.discovery.DiscoveryClient 850 renew - DiscoveryClient_DATAWORKCLOUD-GATEWAY/192.168.216.157:DataWorkCloud-Gateway:8001 - Re-registering apps/DATAWORKCLOUD-GATEWAY
2019-10-14 13:10:53.195 INFO [DiscoveryClient-HeartbeatExecutor-0] com.netflix.discovery.DiscoveryClient 826 register - DiscoveryClient_DATAWORKCLOUD-GATEWAY/192.168.216.157:DataWorkCloud-Gateway:8001: registering service...
2019-10-14 13:10:53.201 INFO [DiscoveryClient-HeartbeatExecutor-0] com.netflix.discovery.DiscoveryClient 835 register - DiscoveryClient_DATAWORKCLOUD-GATEWAY/192.168.216.157:DataWorkCloud-Gateway:8001 - registration status: 204
2019-10-14 13:13:22.290 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 13:18:22.286 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 13:23:22.282 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 13:28:22.177 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 13:33:57.848 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 13:36:52.366 INFO [reactor-http-nio-4] com.webank.wedatasphere.linkis.server.security.SSOUtils$ 42 info - add login userTicketCookie for user allwefantasy.
2019-10-14 13:36:52.514 INFO [reactor-http-nio-4] com.webank.wedatasphere.linkis.gateway.parser.DefaultGatewayParser 42 info - /127.0.0.1:60014 try to heartbeat.
2019-10-14 13:36:52.550 INFO [reactor-http-nio-4] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/execute
2019-10-14 13:36:52.553 INFO [reactor-http-nio-4] com.webank.wedatasphere.linkis.gateway.ujes.parser.EntranceExecutionGatewayParser 42 info - GatewayParser parse requestUri /api/rest_j/v1/entrance/execute to service allwefantasy or mlsql.
2019-10-14 13:36:52.558 WARN [reactor-http-nio-4] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 13:36:52.561 INFO [reactor-http-nio-4] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/execute with parsedService mlsql to ServiceInstance(mlsqlentrance, null)
2019-10-14 13:36:54.912 INFO [reactor-http-nio-4] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_1/status
2019-10-14 13:36:54.913 WARN [reactor-http-nio-4] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 13:36:54.914 INFO [reactor-http-nio-4] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_1/status with parsedService mlsql to ServiceInstance(mlsqlentrance, 192.168.216.157:8889)
2019-10-14 13:36:54,919 ERROR (reactor-http-nio-4) ERROR DefaultErrorWebExceptionHandler - Failed to handle request [GET http://127.0.0.1:8001/api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_1/status]
org.springframework.cloud.gateway.support.NotFoundException: Unable to find instance for 127.0.0.1
at org.springframework.cloud.gateway.filter.LoadBalancerClientFilter.filter(LoadBalancerClientFilter.java:72)
at org.springframework.cloud.gateway.handler.FilteringWebHandler$GatewayFilterAdapter.filter(FilteringWebHandler.java:133)
at org.springframework.cloud.gateway.filter.OrderedGatewayFilter.filter(OrderedGatewayFilter.java:44)
at org.springframework.cloud.gateway.handler.FilteringWebHandler$DefaultGatewayFilterChain.lambda$filter$0(FilteringWebHandler.java:115)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:44)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:275)
at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:849)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.drain(FluxFilterWhen.java:266)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.onNext(FluxFilterWhen.java:134)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onNext(FluxDematerialize.java:114)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onNext(FluxDematerialize.java:42)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drainAsync(FluxFlattenIterable.java:395)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drain(FluxFlattenIterable.java:638)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onNext(FluxFlattenIterable.java:242)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:179)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1461)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.DrainUtils.postCompleteDrain(DrainUtils.java:131)
at reactor.core.publisher.DrainUtils.postComplete(DrainUtils.java:186)
at reactor.core.publisher.FluxMaterialize$MaterializeSubscriber.onComplete(FluxMaterialize.java:134)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drainAsync(FluxFlattenIterable.java:325)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drain(FluxFlattenIterable.java:638)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onComplete(FluxFlattenIterable.java:259)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1463)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:794)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:560)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:426)
at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:265)
at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:201)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:335)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
at reactor.core.publisher.FluxFlatMap.subscribe(FluxFlatMap.java:97)
at reactor.core.publisher.MonoCollectList.subscribe(MonoCollectList.java:59)
at reactor.core.publisher.MonoMapFuseable.subscribe(MonoMapFuseable.java:59)
at reactor.core.publisher.MonoFlattenIterable.subscribe(MonoFlattenIterable.java:101)
at reactor.core.publisher.FluxMaterialize.subscribe(FluxMaterialize.java:40)
at reactor.core.publisher.MonoCollectList.subscribe(MonoCollectList.java:59)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74)
at reactor.core.publisher.MonoFlattenIterable.subscribe(MonoFlattenIterable.java:101)
at reactor.core.publisher.FluxDematerialize.subscribe(FluxDematerialize.java:39)
at reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:54)
at reactor.core.publisher.FluxFilterWhen.subscribe(FluxFilterWhen.java:69)
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
at reactor.core.publisher.MonoMap.subscribe(MonoMap.java:55)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
at reactor.core.publisher.MonoMap.subscribe(MonoMap.java:55)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:442)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:212)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
at reactor.core.publisher.FluxConcatMap.subscribe(FluxConcatMap.java:121)
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
at reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:247)
at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:329)
at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2041)
at reactor.core.publisher.MonoZip$ZipInner.onSubscribe(MonoZip.java:318)
at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:128)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:70)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.ipc.netty.channel.ChannelOperations.applyHandler(ChannelOperations.java:380)
at reactor.ipc.netty.http.server.HttpServerOperations.onHandlerStart(HttpServerOperations.java:398)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:465)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884)
at java.lang.Thread.run(Thread.java:748)
2019-10-14 13:38:36.014 INFO [reactor-http-nio-6] com.webank.wedatasphere.linkis.server.security.SSOUtils$ 42 info - add login userTicketCookie for user allwefantasy.
2019-10-14 13:38:36.081 INFO [reactor-http-nio-6] com.webank.wedatasphere.linkis.gateway.parser.DefaultGatewayParser 42 info - /127.0.0.1:60061 try to heartbeat.
2019-10-14 13:38:36.111 INFO [reactor-http-nio-6] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/execute
2019-10-14 13:38:36.112 INFO [reactor-http-nio-6] com.webank.wedatasphere.linkis.gateway.ujes.parser.EntranceExecutionGatewayParser 42 info - GatewayParser parse requestUri /api/rest_j/v1/entrance/execute to service allwefantasy or mlsql.
2019-10-14 13:38:36.113 WARN [reactor-http-nio-6] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 13:38:36.113 INFO [reactor-http-nio-6] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/execute with parsedService mlsql to ServiceInstance(mlsqlentrance, null)
2019-10-14 13:38:37.066 INFO [reactor-http-nio-6] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_2/status
2019-10-14 13:38:37.067 WARN [reactor-http-nio-6] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 13:38:37.068 INFO [reactor-http-nio-6] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_2/status with parsedService mlsql to ServiceInstance(mlsqlentrance, 192.168.216.157:8889)
2019-10-14 13:38:37,069 ERROR (reactor-http-nio-6) ERROR DefaultErrorWebExceptionHandler - Failed to handle request [GET http://127.0.0.1:8001/api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_2/status]
org.springframework.cloud.gateway.support.NotFoundException: Unable to find instance for 127.0.0.1
at org.springframework.cloud.gateway.filter.LoadBalancerClientFilter.filter(LoadBalancerClientFilter.java:72)
at org.springframework.cloud.gateway.handler.FilteringWebHandler$GatewayFilterAdapter.filter(FilteringWebHandler.java:133)
at org.springframework.cloud.gateway.filter.OrderedGatewayFilter.filter(OrderedGatewayFilter.java:44)
at org.springframework.cloud.gateway.handler.FilteringWebHandler$DefaultGatewayFilterChain.lambda$filter$0(FilteringWebHandler.java:115)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:44)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:275)
at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:849)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.drain(FluxFilterWhen.java:266)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.onNext(FluxFilterWhen.java:134)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onNext(FluxDematerialize.java:114)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onNext(FluxDematerialize.java:42)
at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:243)
at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:201)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.request(FluxDematerialize.java:157)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.onSubscribe(FluxFilterWhen.java:194)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onSubscribe(FluxDematerialize.java:88)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
at reactor.core.publisher.FluxDematerialize.subscribe(FluxDematerialize.java:39)
at reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:54)
at reactor.core.publisher.FluxFilterWhen.subscribe(FluxFilterWhen.java:69)
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
at reactor.core.publisher.MonoMap.subscribe(MonoMap.java:55)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
at reactor.core.publisher.MonoMap.subscribe(MonoMap.java:55)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:442)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:212)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
at reactor.core.publisher.FluxConcatMap.subscribe(FluxConcatMap.java:121)
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
at reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:247)
at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:329)
at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2041)
at reactor.core.publisher.MonoZip$ZipInner.onSubscribe(MonoZip.java:318)
at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:128)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:70)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.ipc.netty.channel.ChannelOperations.applyHandler(ChannelOperations.java:380)
at reactor.ipc.netty.http.server.HttpServerOperations.onHandlerStart(HttpServerOperations.java:398)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:465)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884)
at java.lang.Thread.run(Thread.java:748)
2019-10-14 13:38:57.844 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 13:43:43.573 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.server.security.SSOUtils$ 42 info - add login userTicketCookie for user allwefantasy.
2019-10-14 13:43:43.634 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.parser.DefaultGatewayParser 42 info - /192.168.216.157:60192 try to heartbeat.
2019-10-14 13:43:43.669 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/execute
2019-10-14 13:43:43.669 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.ujes.parser.EntranceExecutionGatewayParser 42 info - GatewayParser parse requestUri /api/rest_j/v1/entrance/execute to service allwefantasy or mlsql.
2019-10-14 13:43:43.670 WARN [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 13:43:43.671 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/execute with parsedService mlsql to ServiceInstance(mlsqlentrance, null)
2019-10-14 13:43:44.618 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_3/status
2019-10-14 13:43:44.619 WARN [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 13:43:44.620 INFO [reactor-http-nio-8] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_3/status with parsedService mlsql to ServiceInstance(mlsqlentrance, 192.168.216.157:8889)
2019-10-14 13:43:44,703 INFO (reactor-http-nio-8) INFO AnnotationConfigApplicationContext - Refreshing SpringClientFactory-192.168.216.157: startup date [Mon Oct 14 13:43:44 CST 2019]; parent: org.springframework.boot.web.reactive.context.AnnotationConfigReactiveWebServerApplicationContext@6a2eea2a
2019-10-14 13:43:44,925 INFO (reactor-http-nio-8) INFO AutowiredAnnotationBeanPostProcessor - JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2019-10-14 13:43:45.228 INFO [reactor-http-nio-8] com.netflix.config.ChainedDynamicProperty 115 checkAndFlip - Flipping property: 192.168.216.157.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647
2019-10-14 13:43:45.255 INFO [reactor-http-nio-8] com.netflix.util.concurrent.ShutdownEnabledTimer 58 <init> - Shutdown hook installed for: NFLoadBalancer-PingTimer-192.168.216.157
2019-10-14 13:43:45.263 INFO [reactor-http-nio-8] com.netflix.loadbalancer.BaseLoadBalancer 192 initWithConfig - Client: 192.168.216.157 instantiated a LoadBalancer: DynamicServerListLoadBalancer:{NFLoadBalancer:name=192.168.216.157,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:null
2019-10-14 13:43:45.267 INFO [reactor-http-nio-8] com.netflix.loadbalancer.DynamicServerListLoadBalancer 222 enableAndInitLearnNewServersFeature - Using serverListUpdater PollingServerListUpdater
2019-10-14 13:43:45.269 INFO [reactor-http-nio-8] com.netflix.loadbalancer.DynamicServerListLoadBalancer 150 restOfInit - DynamicServerListLoadBalancer for client 192.168.216.157 initialized: DynamicServerListLoadBalancer:{NFLoadBalancer:name=192.168.216.157,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList@6bce5331
2019-10-14 13:43:45,339 ERROR (reactor-http-nio-8) ERROR DefaultErrorWebExceptionHandler - Failed to handle request [GET http://192.168.216.157:8001/api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_3/status]
org.springframework.cloud.gateway.support.NotFoundException: Unable to find instance for 192.168.216.157
at org.springframework.cloud.gateway.filter.LoadBalancerClientFilter.filter(LoadBalancerClientFilter.java:72)
at org.springframework.cloud.gateway.handler.FilteringWebHandler$GatewayFilterAdapter.filter(FilteringWebHandler.java:133)
at org.springframework.cloud.gateway.filter.OrderedGatewayFilter.filter(OrderedGatewayFilter.java:44)
at org.springframework.cloud.gateway.handler.FilteringWebHandler$DefaultGatewayFilterChain.lambda$filter$0(FilteringWebHandler.java:115)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:44)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:275)
at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:849)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.drain(FluxFilterWhen.java:266)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.onNext(FluxFilterWhen.java:134)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onNext(FluxDematerialize.java:114)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onNext(FluxDematerialize.java:42)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drainAsync(FluxFlattenIterable.java:395)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drain(FluxFlattenIterable.java:638)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onNext(FluxFlattenIterable.java:242)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:179)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1461)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.DrainUtils.postCompleteDrain(DrainUtils.java:131)
at reactor.core.publisher.DrainUtils.postComplete(DrainUtils.java:186)
at reactor.core.publisher.FluxMaterialize$MaterializeSubscriber.onComplete(FluxMaterialize.java:134)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drainAsync(FluxFlattenIterable.java:325)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.drain(FluxFlattenIterable.java:638)
at reactor.core.publisher.FluxFlattenIterable$FlattenIterableSubscriber.onComplete(FluxFlattenIterable.java:259)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1463)
at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:794)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:560)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:540)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:426)
at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:265)
at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:201)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:335)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
at reactor.core.publisher.FluxFlatMap.subscribe(FluxFlatMap.java:97)
at reactor.core.publisher.MonoCollectList.subscribe(MonoCollectList.java:59)
at reactor.core.publisher.MonoMapFuseable.subscribe(MonoMapFuseable.java:59)
at reactor.core.publisher.MonoFlattenIterable.subscribe(MonoFlattenIterable.java:101)
at reactor.core.publisher.FluxMaterialize.subscribe(FluxMaterialize.java:40)
at reactor.core.publisher.MonoCollectList.subscribe(MonoCollectList.java:59)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74)
at reactor.core.publisher.MonoFlattenIterable.subscribe(MonoFlattenIterable.java:101)
at reactor.core.publisher.FluxDematerialize.subscribe(FluxDematerialize.java:39)
at reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:54)
at reactor.core.publisher.FluxFilterWhen.subscribe(FluxFilterWhen.java:69)
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
at reactor.core.publisher.MonoMap.subscribe(MonoMap.java:55)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
at reactor.core.publisher.MonoMap.subscribe(MonoMap.java:55)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:442)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:212)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
at reactor.core.publisher.FluxConcatMap.subscribe(FluxConcatMap.java:121)
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
at reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:247)
at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:329)
at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2041)
at reactor.core.publisher.MonoZip$ZipInner.onSubscribe(MonoZip.java:318)
at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:128)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:70)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.ipc.netty.channel.ChannelOperations.applyHandler(ChannelOperations.java:380)
at reactor.ipc.netty.http.server.HttpServerOperations.onHandlerStart(HttpServerOperations.java:398)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:465)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884)
at java.lang.Thread.run(Thread.java:748)
2019-10-14 13:43:57.838 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 13:44:22.178 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.server.security.SSOUtils$ 42 info - add login userTicketCookie for user allwefantasy.
2019-10-14 13:44:22.246 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.parser.DefaultGatewayParser 42 info - /192.168.216.157:60201 try to heartbeat.
2019-10-14 13:44:22.269 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/execute
2019-10-14 13:44:22.270 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.ujes.parser.EntranceExecutionGatewayParser 42 info - GatewayParser parse requestUri /api/rest_j/v1/entrance/execute to service allwefantasy or mlsql.
2019-10-14 13:44:22.270 WARN [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 13:44:22.271 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/execute with parsedService mlsql to ServiceInstance(mlsqlentrance, null)
2019-10-14 13:44:22.985 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.security.GatewaySSOUtils$ 42 info - No login needed for proxy uri: /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_4/status
2019-10-14 13:44:22.986 WARN [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.ujes.route.EntranceGatewayRouter 51 warn - Cannot find a service which named allwefantasy, now redirect to mlsql entrance.
2019-10-14 13:44:22.987 INFO [reactor-http-nio-2] com.webank.wedatasphere.linkis.gateway.route.DefaultGatewayRouter 42 info - GatewayRouter route requestUri /api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_4/status with parsedService mlsql to ServiceInstance(mlsqlentrance, 192.168.216.157:8889)
2019-10-14 13:44:22,988 ERROR (reactor-http-nio-2) ERROR DefaultErrorWebExceptionHandler - Failed to handle request [GET http://192.168.216.157:8001/api/rest_j/v1/entrance/120520allwefantasymlsql192.168.216.157:8889allwefantasy_allwefantasy_4/status]
org.springframework.cloud.gateway.support.NotFoundException: Unable to find instance for 192.168.216.157
at org.springframework.cloud.gateway.filter.LoadBalancerClientFilter.filter(LoadBalancerClientFilter.java:72)
at org.springframework.cloud.gateway.handler.FilteringWebHandler$GatewayFilterAdapter.filter(FilteringWebHandler.java:133)
at org.springframework.cloud.gateway.filter.OrderedGatewayFilter.filter(OrderedGatewayFilter.java:44)
at org.springframework.cloud.gateway.handler.FilteringWebHandler$DefaultGatewayFilterChain.lambda$filter$0(FilteringWebHandler.java:115)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:44)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:275)
at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:849)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)
at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.drain(FluxFilterWhen.java:266)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.onNext(FluxFilterWhen.java:134)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onNext(FluxDematerialize.java:114)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onNext(FluxDematerialize.java:42)
at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:243)
at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:201)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.request(FluxDematerialize.java:157)
at reactor.core.publisher.FluxFilterWhen$FluxFilterWhenSubscriber.onSubscribe(FluxFilterWhen.java:194)
at reactor.core.publisher.FluxDematerialize$DematerializeSubscriber.onSubscribe(FluxDematerialize.java:88)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
at reactor.core.publisher.FluxDematerialize.subscribe(FluxDematerialize.java:39)
at reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:54)
at reactor.core.publisher.FluxFilterWhen.subscribe(FluxFilterWhen.java:69)
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
at reactor.core.publisher.MonoMap.subscribe(MonoMap.java:55)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
at reactor.core.publisher.MonoMap.subscribe(MonoMap.java:55)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:442)
at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:212)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
at reactor.core.publisher.FluxConcatMap.subscribe(FluxConcatMap.java:121)
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
at reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:247)
at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:329)
at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2041)
at reactor.core.publisher.MonoZip$ZipInner.onSubscribe(MonoZip.java:318)
at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:128)
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
at reactor.core.publisher.Mono.subscribe(Mono.java:3590)
at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:70)
at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
at reactor.ipc.netty.channel.ChannelOperations.applyHandler(ChannelOperations.java:380)
at reactor.ipc.netty.http.server.HttpServerOperations.onHandlerStart(HttpServerOperations.java:398)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:465)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884)
at java.lang.Thread.run(Thread.java:748)
2019-10-14 13:48:57.836 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 13:53:57.833 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 13:56:04.759 INFO [BDP-Default-Scheduler-Thread-3] com.webank.wedatasphere.linkis.server.security.SSOUtils$ 42 info - remove timeout userTicket 1bYAk97XNnIPzfZTu0hxEKb3LrvSxCXodAczFm91gPo=, since the last access time is 1571028315291.
2019-10-14 13:58:57.828 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:03:57.820 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:08:57.820 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:13:57.817 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:18:57.815 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:23:57.811 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:28:57.806 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:33:57.803 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:38:04.664 INFO [BDP-Default-Scheduler-Thread-3] com.webank.wedatasphere.linkis.server.security.SSOUtils$ 42 info - remove timeout userTicket 1bYAk97XNnIPzfZTu0hxEPyfx86+3PTadHCN3J/3tys=, since the last access time is 1571031412388.
2019-10-14 14:38:57.800 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:43:57.795 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:44:04.647 INFO [BDP-Default-Scheduler-Thread-18] com.webank.wedatasphere.linkis.server.security.SSOUtils$ 42 info - remove timeout userTicket 1bYAk97XNnIPzfZTu0hxEPyfx86+3PTaOma053Yhzek=, since the last access time is 1571031516018.
2019-10-14 14:44:04.651 INFO [BDP-Default-Scheduler-Thread-18] com.webank.wedatasphere.linkis.server.security.SSOUtils$ 42 info - remove timeout userTicket 1bYAk97XNnIPzfZTu0hxEPyfx86+3PTatbgZSYofr0U=, since the last access time is 1571031823575.
2019-10-14 14:48:57.792 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:50:04.640 INFO [BDP-Default-Scheduler-Thread-20] com.webank.wedatasphere.linkis.server.security.SSOUtils$ 42 info - remove timeout userTicket 1bYAk97XNnIPzfZTu0hxEPyfx86+3PTa9hR6zKUJ2Ak=, since the last access time is 1571031862181.
2019-10-14 14:53:57.785 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 14:58:57.782 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration
2019-10-14 15:03:57.780 INFO [AsyncResolver-bootstrap-executor-0] com.netflix.discovery.shared.resolver.aws.ConfigClusterResolver 43 getClusterEndpoints - Resolving eureka endpoints via configuration