:2025-07-18 13:48:42.698 INFO main c.p.p.m.PigMonitorApplication: Starting PigMonitorApplication using Java 21.0.6 with PID 26400 (D:\develop\workCode\seo\pig-visual\pig-monitor\target\classes started by L in D:\develop\workCode\seo) :2025-07-18 13:48:42.700 INFO main c.p.p.m.PigMonitorApplication: No active profile set, falling back to 1 default profile: "default" :2025-07-18 13:48:42.727 INFO main c.a.c.n.c.NacosConfigDataLoader: [Nacos Config] Load config[dataId=pig-monitor.yml, group=DEFAULT_GROUP] success :2025-07-18 13:48:42.727 INFO main c.a.c.n.c.NacosConfigDataLoader: [Nacos Config] Load config[dataId=application.yml, group=DEFAULT_GROUP] success :2025-07-18 13:48:43.432 INFO main o.s.c.c.s.GenericScope: BeanFactory id=885ba4b2-e630-31c4-9ce8-2ff3fc036f53 :2025-07-18 13:48:43.452 INFO main c.u.j.c.EnableEncryptablePropertiesBeanFactoryPostProcessor: Post-processing PropertySource instances :2025-07-18 13:48:43.452 INFO main c.u.j.EncryptablePropertySourceConverter: Skipping PropertySource configurationProperties [class org.springframework.boot.context.properties.source.ConfigurationPropertySourcesPropertySource :2025-07-18 13:48:43.453 INFO main c.u.j.EncryptablePropertySourceConverter: Skipping PropertySource servletConfigInitParams [class org.springframework.core.env.PropertySource$StubPropertySource :2025-07-18 13:48:43.453 INFO main c.u.j.EncryptablePropertySourceConverter: Skipping PropertySource servletContextInitParams [class org.springframework.core.env.PropertySource$StubPropertySource :2025-07-18 13:48:43.454 INFO main c.u.j.EncryptablePropertySourceConverter: Converting PropertySource systemProperties [org.springframework.core.env.PropertiesPropertySource] to EncryptableMapPropertySourceWrapper :2025-07-18 13:48:43.454 INFO main c.u.j.EncryptablePropertySourceConverter: Converting PropertySource systemEnvironment [org.springframework.boot.env.SystemEnvironmentPropertySourceEnvironmentPostProcessor$OriginAwareSystemEnvironmentPropertySource] to EncryptableSystemEnvironmentPropertySourceWrapper :2025-07-18 13:48:43.454 INFO main c.u.j.EncryptablePropertySourceConverter: Converting PropertySource random [org.springframework.boot.env.RandomValuePropertySource] to EncryptablePropertySourceWrapper :2025-07-18 13:48:43.454 INFO main c.u.j.EncryptablePropertySourceConverter: Converting PropertySource cachedrandom [org.springframework.cloud.util.random.CachedRandomPropertySource] to EncryptablePropertySourceWrapper :2025-07-18 13:48:43.454 INFO main c.u.j.EncryptablePropertySourceConverter: Converting PropertySource DEFAULT_GROUP@pig-monitor.yml [org.springframework.boot.env.OriginTrackedMapPropertySource] to EncryptableMapPropertySourceWrapper :2025-07-18 13:48:43.454 INFO main c.u.j.EncryptablePropertySourceConverter: Converting PropertySource DEFAULT_GROUP@application.yml [org.springframework.boot.env.OriginTrackedMapPropertySource] to EncryptableMapPropertySourceWrapper :2025-07-18 13:48:43.454 INFO main c.u.j.EncryptablePropertySourceConverter: Converting PropertySource Config resource 'class path resource [application.yml]' via location 'optional:classpath:/' [org.springframework.boot.env.OriginTrackedMapPropertySource] to EncryptableMapPropertySourceWrapper :2025-07-18 13:48:43.455 INFO main c.u.j.EncryptablePropertySourceConverter: Converting PropertySource springCloudClientHostInfo [org.springframework.core.env.MapPropertySource] to EncryptableMapPropertySourceWrapper :2025-07-18 13:48:43.455 INFO main c.u.j.EncryptablePropertySourceConverter: Converting PropertySource applicationInfo [org.springframework.boot.ApplicationInfoPropertySource] to EncryptableMapPropertySourceWrapper :2025-07-18 13:48:43.619 WARN main i.u.w.jsr: UT026010: Buffer pool was not set on WebSocketDeploymentInfo, the default pool will be used :2025-07-18 13:48:43.630 INFO main i.u.servlet: Initializing Spring embedded WebApplicationContext :2025-07-18 13:48:43.631 INFO main o.s.b.w.s.c.ServletWebServerApplicationContext: Root WebApplicationContext: initialization completed in 902 ms :2025-07-18 13:48:43.670 INFO main c.u.j.f.DefaultLazyPropertyFilter: Property Filter custom Bean not found with name 'encryptablePropertyFilter'. Initializing Default Property Filter :2025-07-18 13:48:43.674 INFO main c.u.j.r.DefaultLazyPropertyResolver: Property Resolver custom Bean not found with name 'encryptablePropertyResolver'. Initializing Default Property Resolver :2025-07-18 13:48:43.675 INFO main c.u.j.d.DefaultLazyPropertyDetector: Property Detector custom Bean not found with name 'encryptablePropertyDetector'. Initializing Default Property Detector :2025-07-18 13:48:43.677 INFO main c.u.j.e.DefaultLazyEncryptor: String Encryptor custom Bean not found with name 'jasyptStringEncryptor'. Initializing Default String Encryptor :2025-07-18 13:48:43.682 INFO main c.u.j.c.StringEncryptorBuilder: Encryptor config not found for property jasypt.encryptor.key-obtention-iterations, using default value: 1000 :2025-07-18 13:48:43.682 INFO main c.u.j.c.StringEncryptorBuilder: Encryptor config not found for property jasypt.encryptor.pool-size, using default value: 1 :2025-07-18 13:48:43.683 INFO main c.u.j.c.StringEncryptorBuilder: Encryptor config not found for property jasypt.encryptor.provider-name, using default value: null :2025-07-18 13:48:43.683 INFO main c.u.j.c.StringEncryptorBuilder: Encryptor config not found for property jasypt.encryptor.provider-class-name, using default value: null :2025-07-18 13:48:43.683 INFO main c.u.j.c.StringEncryptorBuilder: Encryptor config not found for property jasypt.encryptor.salt-generator-classname, using default value: org.jasypt.salt.RandomSaltGenerator :2025-07-18 13:48:43.685 INFO main c.u.j.c.StringEncryptorBuilder: Encryptor config not found for property jasypt.encryptor.string-output-type, using default value: base64 :2025-07-18 13:48:43.888 INFO main o.s.s.c.a.a.c.InitializeUserDetailsBeanManagerConfigurer$InitializeUserDetailsManagerConfigurer: Global AuthenticationManager configured with UserDetailsService bean with name userDetailsService :2025-07-18 13:48:44.135 WARN main o.s.b.a.t.ThymeleafAutoConfiguration$DefaultTemplateResolverConfiguration: Cannot find template location: classpath:/templates/ (please add some templates, check your Thymeleaf configuration, or set spring.thymeleaf.check-template-location=false) :2025-07-18 13:48:45.174 INFO main o.s.c.c.u.InetUtils: Cannot determine local hostname :2025-07-18 13:48:46.361 INFO main o.s.c.c.u.InetUtils: Cannot determine local hostname :2025-07-18 13:48:47.381 INFO main o.s.c.c.u.InetUtils: Cannot determine local hostname :2025-07-18 13:48:47.547 INFO main o.s.b.a.e.w.EndpointLinksResolver: Exposing 18 endpoints beneath base path '/actuator' :2025-07-18 13:48:47.606 INFO main i.undertow: starting server: Undertow - 2.3.18.Final :2025-07-18 13:48:47.610 INFO main o.xnio: XNIO version 3.8.16.Final :2025-07-18 13:48:47.618 INFO main o.x.nio: XNIO NIO Implementation Version 3.8.16.Final :2025-07-18 13:48:47.637 INFO main o.j.threads: JBoss Threads version 3.5.0.Final :2025-07-18 13:48:47.695 INFO main o.s.b.w.e.u.UndertowWebServer: Undertow started on port 5001 (http) with context path '/' :2025-07-18 13:48:47.697 INFO main c.u.j.c.RefreshScopeRefreshedEventListener: Refreshing cached encryptable property sources on ServletWebServerInitializedEvent :2025-07-18 13:48:47.697 INFO main c.u.j.c.CachingDelegateEncryptablePropertySource: Property Source systemProperties refreshed :2025-07-18 13:48:47.697 INFO main c.u.j.c.CachingDelegateEncryptablePropertySource: Property Source systemEnvironment refreshed :2025-07-18 13:48:47.697 INFO main c.u.j.c.CachingDelegateEncryptablePropertySource: Property Source random refreshed :2025-07-18 13:48:47.697 INFO main c.u.j.c.CachingDelegateEncryptablePropertySource: Property Source cachedrandom refreshed :2025-07-18 13:48:47.697 INFO main c.u.j.c.CachingDelegateEncryptablePropertySource: Property Source DEFAULT_GROUP@pig-monitor.yml refreshed :2025-07-18 13:48:47.697 INFO main c.u.j.c.CachingDelegateEncryptablePropertySource: Property Source DEFAULT_GROUP@application.yml refreshed :2025-07-18 13:48:47.697 INFO main c.u.j.c.CachingDelegateEncryptablePropertySource: Property Source Config resource 'class path resource [application.yml]' via location 'optional:classpath:/' refreshed :2025-07-18 13:48:47.697 INFO main c.u.j.c.CachingDelegateEncryptablePropertySource: Property Source springCloudClientHostInfo refreshed :2025-07-18 13:48:47.697 INFO main c.u.j.c.CachingDelegateEncryptablePropertySource: Property Source applicationInfo refreshed :2025-07-18 13:48:47.697 INFO main c.u.j.EncryptablePropertySourceConverter: Skipping PropertySource configurationProperties [class org.springframework.boot.context.properties.source.ConfigurationPropertySourcesPropertySource :2025-07-18 13:48:47.697 INFO main c.u.j.EncryptablePropertySourceConverter: Skipping PropertySource servletConfigInitParams [class org.springframework.core.env.PropertySource$StubPropertySource :2025-07-18 13:48:47.697 INFO main c.u.j.EncryptablePropertySourceConverter: Converting PropertySource servletContextInitParams [org.springframework.web.context.support.ServletContextPropertySource] to EncryptableEnumerablePropertySourceWrapper :2025-07-18 13:48:47.697 INFO main c.u.j.EncryptablePropertySourceConverter: Converting PropertySource Management Server [org.springframework.boot.actuate.autoconfigure.web.server.ManagementContextAutoConfiguration$LocalManagementPortPropertySource] to EncryptableEnumerablePropertySourceWrapper :2025-07-18 13:48:48.707 INFO main o.s.c.c.u.InetUtils: Cannot determine local hostname :2025-07-18 13:48:49.725 INFO main o.s.c.c.u.InetUtils: Cannot determine local hostname :2025-07-18 13:48:49.846 INFO main c.a.c.n.r.NacosServiceRegistry: nacos registry, DEFAULT_GROUP pig-monitor 169.254.32.119:5001 register finished :2025-07-18 13:48:50.114 INFO XNIO-1 task-2 i.u.servlet: Initializing Spring DispatcherServlet 'dispatcherServlet' :2025-07-18 13:48:50.114 INFO XNIO-1 task-2 o.s.w.s.DispatcherServlet: Initializing Servlet 'dispatcherServlet' :2025-07-18 13:48:50.116 INFO XNIO-1 task-2 o.s.w.s.DispatcherServlet: Completed initialization in 2 ms :2025-07-18 13:48:50.116 INFO main c.a.c.n.d.NacosDiscoveryHeartBeatPublisher: Start nacos heartBeat task scheduler. :2025-07-18 13:48:50.125 INFO main c.p.p.m.PigMonitorApplication: Started PigMonitorApplication in 9.457 seconds (process running for 9.872) :2025-07-18 13:48:50.132 INFO main c.a.c.n.r.NacosContextRefresher: [Nacos Config] Listening config: dataId=application.yml, group=DEFAULT_GROUP :2025-07-18 13:48:50.133 INFO main c.a.c.n.r.NacosContextRefresher: [Nacos Config] Listening config: dataId=pig-monitor.yml, group=DEFAULT_GROUP :2025-07-18 14:23:44.339 INFO parallel-6 d.c.b.a.s.s.StatusUpdater: Couldn't retrieve status for Instance(id=fe788dc64c5c, version=2, registration=Registration(name=pig-quartz, managementUrl=http://169.254.32.119:5007/actuator, healthUrl=http://169.254.32.119:5007/actuator/health, serviceUrl=http://169.254.32.119:5007, source=discovery), registered=true, statusInfo=StatusInfo(status=UP, details={nacosConfig={status=UP}, diskSpace={status=UP, details={total=807073214464, free=572627021824, threshold=10485760, path=D:\develop\workCode\seo\., exists=true}}, ping={status=UP}, discoveryComposite={status=UP, components={discoveryClient={status=UP, details={services=[pig-gateway, pig-monitor, pig-quartz, pig-upms-biz, pig-codegen, pig-auth]}}}}, refreshScope={status=UP}, nacosDiscovery={status=UP}, ssl={status=UP, details={validChains=[], invalidChains=[]}}, db={status=UP, details={database=MySQL, validationQuery=isValid()}}, redis={status=UP, details={version=6.0.20}}}), statusTimestamp=2025-07-18T05:49:20.280115700Z, info=Info(values={}), endpoints=Endpoints(endpoints={sentinel=Endpoint(id=sentinel, url=http://169.254.32.119:5007/actuator/sentinel), caches=Endpoint(id=caches, url=http://169.254.32.119:5007/actuator/caches), loggers=Endpoint(id=loggers, url=http://169.254.32.119:5007/actuator/loggers), logfile=Endpoint(id=logfile, url=http://169.254.32.119:5007/actuator/logfile), nacosconfig=Endpoint(id=nacosconfig, url=http://169.254.32.119:5007/actuator/nacosconfig), health=Endpoint(id=health, url=http://169.254.32.119:5007/actuator/health), quartz=Endpoint(id=quartz, url=http://169.254.32.119:5007/actuator/quartz), refresh=Endpoint(id=refresh, url=http://169.254.32.119:5007/actuator/refresh), env=Endpoint(id=env, url=http://169.254.32.119:5007/actuator/env), nacosdiscovery=Endpoint(id=nacosdiscovery, url=http://169.254.32.119:5007/actuator/nacosdiscovery), serviceregistry=Endpoint(id=serviceregistry, url=http://169.254.32.119:5007/actuator/serviceregistry), features=Endpoint(id=features, url=http://169.254.32.119:5007/actuator/features), scheduledtasks=Endpoint(id=scheduledtasks, url=http://169.254.32.119:5007/actuator/scheduledtasks), mappings=Endpoint(id=mappings, url=http://169.254.32.119:5007/actuator/mappings), beans=Endpoint(id=beans, url=http://169.254.32.119:5007/actuator/beans), configprops=Endpoint(id=configprops, url=http://169.254.32.119:5007/actuator/configprops), threaddump=Endpoint(id=threaddump, url=http://169.254.32.119:5007/actuator/threaddump), sbom=Endpoint(id=sbom, url=http://169.254.32.119:5007/actuator/sbom), metrics=Endpoint(id=metrics, url=http://169.254.32.119:5007/actuator/metrics), conditions=Endpoint(id=conditions, url=http://169.254.32.119:5007/actuator/conditions), info=Endpoint(id=info, url=http://169.254.32.119:5007/actuator/info)}), buildVersion=null, tags=Tags(values={})) java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 9000ms in 'log' (and no fallback has been configured) at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.handleTimeout(FluxTimeout.java:296) at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.doTimeout(FluxTimeout.java:281) at reactor.core.publisher.FluxTimeout$TimeoutTimeoutSubscriber.onNext(FluxTimeout.java:420) at reactor.core.publisher.FluxOnErrorReturn$ReturnSubscriber.onNext(FluxOnErrorReturn.java:162) at reactor.core.publisher.MonoDelay$MonoDelayRunnable.propagateDelay(MonoDelay.java:270) at reactor.core.publisher.MonoDelay$MonoDelayRunnable.run(MonoDelay.java:285) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.lang.Thread.run(Thread.java:1583) :2025-07-18 14:23:44.339 INFO parallel-10 d.c.b.a.s.s.StatusUpdater: Couldn't retrieve status for Instance(id=83336318f780, version=2, registration=Registration(name=pig-codegen, managementUrl=http://169.254.32.119:5002/actuator, healthUrl=http://169.254.32.119:5002/actuator/health, serviceUrl=http://169.254.32.119:5002, source=discovery), registered=true, statusInfo=StatusInfo(status=UP, details={nacosConfig={status=UP}, diskSpace={status=UP, details={total=807073214464, free=572627021824, threshold=10485760, path=D:\develop\workCode\seo\., exists=true}}, ping={status=UP}, discoveryComposite={status=UP, components={discoveryClient={status=UP, details={services=[pig-gateway, pig-monitor, pig-quartz, pig-upms-biz, pig-codegen, pig-auth]}}}}, refreshScope={status=UP}, nacosDiscovery={status=UP}, ssl={status=UP, details={validChains=[], invalidChains=[]}}, db={status=UP, details={database=MySQL, validationQuery=isValid()}}, redis={status=UP, details={version=6.0.20}}}), statusTimestamp=2025-07-18T05:49:20.326934300Z, info=Info(values={}), endpoints=Endpoints(endpoints={sentinel=Endpoint(id=sentinel, url=http://169.254.32.119:5002/actuator/sentinel), caches=Endpoint(id=caches, url=http://169.254.32.119:5002/actuator/caches), loggers=Endpoint(id=loggers, url=http://169.254.32.119:5002/actuator/loggers), logfile=Endpoint(id=logfile, url=http://169.254.32.119:5002/actuator/logfile), nacosconfig=Endpoint(id=nacosconfig, url=http://169.254.32.119:5002/actuator/nacosconfig), health=Endpoint(id=health, url=http://169.254.32.119:5002/actuator/health), refresh=Endpoint(id=refresh, url=http://169.254.32.119:5002/actuator/refresh), env=Endpoint(id=env, url=http://169.254.32.119:5002/actuator/env), nacosdiscovery=Endpoint(id=nacosdiscovery, url=http://169.254.32.119:5002/actuator/nacosdiscovery), serviceregistry=Endpoint(id=serviceregistry, url=http://169.254.32.119:5002/actuator/serviceregistry), features=Endpoint(id=features, url=http://169.254.32.119:5002/actuator/features), scheduledtasks=Endpoint(id=scheduledtasks, url=http://169.254.32.119:5002/actuator/scheduledtasks), mappings=Endpoint(id=mappings, url=http://169.254.32.119:5002/actuator/mappings), beans=Endpoint(id=beans, url=http://169.254.32.119:5002/actuator/beans), configprops=Endpoint(id=configprops, url=http://169.254.32.119:5002/actuator/configprops), threaddump=Endpoint(id=threaddump, url=http://169.254.32.119:5002/actuator/threaddump), sbom=Endpoint(id=sbom, url=http://169.254.32.119:5002/actuator/sbom), metrics=Endpoint(id=metrics, url=http://169.254.32.119:5002/actuator/metrics), conditions=Endpoint(id=conditions, url=http://169.254.32.119:5002/actuator/conditions), info=Endpoint(id=info, url=http://169.254.32.119:5002/actuator/info)}), buildVersion=null, tags=Tags(values={})) java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 9000ms in 'log' (and no fallback has been configured) at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.handleTimeout(FluxTimeout.java:296) at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.doTimeout(FluxTimeout.java:281) at reactor.core.publisher.FluxTimeout$TimeoutTimeoutSubscriber.onNext(FluxTimeout.java:420) at reactor.core.publisher.FluxOnErrorReturn$ReturnSubscriber.onNext(FluxOnErrorReturn.java:162) at reactor.core.publisher.MonoDelay$MonoDelayRunnable.propagateDelay(MonoDelay.java:270) at reactor.core.publisher.MonoDelay$MonoDelayRunnable.run(MonoDelay.java:285) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.lang.Thread.run(Thread.java:1583) :2025-07-18 14:23:44.339 INFO parallel-8 d.c.b.a.s.s.StatusUpdater: Couldn't retrieve status for Instance(id=b92054537bc9, version=2, registration=Registration(name=pig-gateway, managementUrl=http://169.254.32.119:9999/actuator, healthUrl=http://169.254.32.119:9999/actuator/health, serviceUrl=http://169.254.32.119:9999, source=discovery), registered=true, statusInfo=StatusInfo(status=UP, details={reactiveDiscoveryClients={status=UP, components={Simple Reactive Discovery Client={status=UP, details={services=[]}}}}, nacosConfig={status=UP}, diskSpace={status=UP, details={total=807073214464, free=572631257088, threshold=10485760, path=D:\develop\workCode\seo\., exists=true}}, ping={status=UP}, discoveryComposite={status=UP, components={discoveryClient={status=UP, details={services=[pig-gateway, pig-monitor, pig-upms-biz, pig-auth]}}}}, refreshScope={status=UP}, nacosDiscovery={status=UP}, ssl={status=UP, details={validChains=[], invalidChains=[]}}, redis={status=UP, details={version=6.0.20}}}), statusTimestamp=2025-07-18T05:48:50.159473900Z, info=Info(values={}), endpoints=Endpoints(endpoints={caches=Endpoint(id=caches, url=http://169.254.32.119:9999/actuator/caches), loggers=Endpoint(id=loggers, url=http://169.254.32.119:9999/actuator/loggers), nacosconfig=Endpoint(id=nacosconfig, url=http://169.254.32.119:9999/actuator/nacosconfig), health=Endpoint(id=health, url=http://169.254.32.119:9999/actuator/health), refresh=Endpoint(id=refresh, url=http://169.254.32.119:9999/actuator/refresh), env=Endpoint(id=env, url=http://169.254.32.119:9999/actuator/env), nacosdiscovery=Endpoint(id=nacosdiscovery, url=http://169.254.32.119:9999/actuator/nacosdiscovery), serviceregistry=Endpoint(id=serviceregistry, url=http://169.254.32.119:9999/actuator/serviceregistry), features=Endpoint(id=features, url=http://169.254.32.119:9999/actuator/features), scheduledtasks=Endpoint(id=scheduledtasks, url=http://169.254.32.119:9999/actuator/scheduledtasks), mappings=Endpoint(id=mappings, url=http://169.254.32.119:9999/actuator/mappings), beans=Endpoint(id=beans, url=http://169.254.32.119:9999/actuator/beans), configprops=Endpoint(id=configprops, url=http://169.254.32.119:9999/actuator/configprops), threaddump=Endpoint(id=threaddump, url=http://169.254.32.119:9999/actuator/threaddump), sbom=Endpoint(id=sbom, url=http://169.254.32.119:9999/actuator/sbom), metrics=Endpoint(id=metrics, url=http://169.254.32.119:9999/actuator/metrics), conditions=Endpoint(id=conditions, url=http://169.254.32.119:9999/actuator/conditions), info=Endpoint(id=info, url=http://169.254.32.119:9999/actuator/info)}), buildVersion=null, tags=Tags(values={})) java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 9000ms in 'log' (and no fallback has been configured) at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.handleTimeout(FluxTimeout.java:296) at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.doTimeout(FluxTimeout.java:281) at reactor.core.publisher.FluxTimeout$TimeoutTimeoutSubscriber.onNext(FluxTimeout.java:420) at reactor.core.publisher.FluxOnErrorReturn$ReturnSubscriber.onNext(FluxOnErrorReturn.java:162) at reactor.core.publisher.MonoDelay$MonoDelayRunnable.propagateDelay(MonoDelay.java:270) at reactor.core.publisher.MonoDelay$MonoDelayRunnable.run(MonoDelay.java:285) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.lang.Thread.run(Thread.java:1583) :2025-07-18 14:23:54.349 INFO parallel-15 d.c.b.a.s.s.StatusUpdater: Couldn't retrieve status for Instance(id=522f7024e859, version=2, registration=Registration(name=pig-auth, managementUrl=http://169.254.32.119:3000/actuator, healthUrl=http://169.254.32.119:3000/actuator/health, serviceUrl=http://169.254.32.119:3000, source=discovery), registered=true, statusInfo=StatusInfo(status=UP, details={nacosConfig={status=UP}, diskSpace={status=UP, details={total=807073214464, free=572631257088, threshold=10485760, path=D:\develop\workCode\seo\., exists=true}}, ping={status=UP}, discoveryComposite={status=UP, components={discoveryClient={status=UP, details={services=[pig-gateway, pig-monitor, pig-upms-biz, pig-auth]}}}}, refreshScope={status=UP}, nacosDiscovery={status=UP}, ssl={status=UP, details={validChains=[], invalidChains=[]}}, redis={status=UP, details={version=6.0.20}}}), statusTimestamp=2025-07-18T05:48:50.226662Z, info=Info(values={}), endpoints=Endpoints(endpoints={sentinel=Endpoint(id=sentinel, url=http://169.254.32.119:3000/actuator/sentinel), caches=Endpoint(id=caches, url=http://169.254.32.119:3000/actuator/caches), loggers=Endpoint(id=loggers, url=http://169.254.32.119:3000/actuator/loggers), logfile=Endpoint(id=logfile, url=http://169.254.32.119:3000/actuator/logfile), nacosconfig=Endpoint(id=nacosconfig, url=http://169.254.32.119:3000/actuator/nacosconfig), health=Endpoint(id=health, url=http://169.254.32.119:3000/actuator/health), refresh=Endpoint(id=refresh, url=http://169.254.32.119:3000/actuator/refresh), env=Endpoint(id=env, url=http://169.254.32.119:3000/actuator/env), nacosdiscovery=Endpoint(id=nacosdiscovery, url=http://169.254.32.119:3000/actuator/nacosdiscovery), serviceregistry=Endpoint(id=serviceregistry, url=http://169.254.32.119:3000/actuator/serviceregistry), features=Endpoint(id=features, url=http://169.254.32.119:3000/actuator/features), scheduledtasks=Endpoint(id=scheduledtasks, url=http://169.254.32.119:3000/actuator/scheduledtasks), mappings=Endpoint(id=mappings, url=http://169.254.32.119:3000/actuator/mappings), beans=Endpoint(id=beans, url=http://169.254.32.119:3000/actuator/beans), configprops=Endpoint(id=configprops, url=http://169.254.32.119:3000/actuator/configprops), threaddump=Endpoint(id=threaddump, url=http://169.254.32.119:3000/actuator/threaddump), sbom=Endpoint(id=sbom, url=http://169.254.32.119:3000/actuator/sbom), metrics=Endpoint(id=metrics, url=http://169.254.32.119:3000/actuator/metrics), conditions=Endpoint(id=conditions, url=http://169.254.32.119:3000/actuator/conditions), info=Endpoint(id=info, url=http://169.254.32.119:3000/actuator/info)}), buildVersion=null, tags=Tags(values={})) java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 9000ms in 'log' (and no fallback has been configured) at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.handleTimeout(FluxTimeout.java:296) at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.doTimeout(FluxTimeout.java:281) at reactor.core.publisher.FluxTimeout$TimeoutTimeoutSubscriber.onNext(FluxTimeout.java:420) at reactor.core.publisher.FluxOnErrorReturn$ReturnSubscriber.onNext(FluxOnErrorReturn.java:162) at reactor.core.publisher.MonoDelay$MonoDelayRunnable.propagateDelay(MonoDelay.java:270) at reactor.core.publisher.MonoDelay$MonoDelayRunnable.run(MonoDelay.java:285) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.lang.Thread.run(Thread.java:1583) :2025-07-18 14:23:54.349 INFO parallel-12 d.c.b.a.s.s.StatusUpdater: Couldn't retrieve status for Instance(id=e1f621ea21bb, version=2, registration=Registration(name=pig-upms-biz, managementUrl=http://169.254.32.119:4000/actuator, healthUrl=http://169.254.32.119:4000/actuator/health, serviceUrl=http://169.254.32.119:4000, source=discovery), registered=true, statusInfo=StatusInfo(status=UP, details={nacosConfig={status=UP}, diskSpace={status=UP, details={total=807073214464, free=572631257088, threshold=10485760, path=D:\develop\workCode\seo\., exists=true}}, ping={status=UP}, discoveryComposite={status=UP, components={discoveryClient={status=UP, details={services=[pig-gateway, pig-monitor, pig-upms-biz, pig-auth]}}}}, refreshScope={status=UP}, nacosDiscovery={status=UP}, ssl={status=UP, details={validChains=[], invalidChains=[]}}, db={status=UP, details={database=MySQL, validationQuery=isValid()}}, redis={status=UP, details={version=6.0.20}}}), statusTimestamp=2025-07-18T05:48:50.159473900Z, info=Info(values={}), endpoints=Endpoints(endpoints={sentinel=Endpoint(id=sentinel, url=http://169.254.32.119:4000/actuator/sentinel), caches=Endpoint(id=caches, url=http://169.254.32.119:4000/actuator/caches), loggers=Endpoint(id=loggers, url=http://169.254.32.119:4000/actuator/loggers), logfile=Endpoint(id=logfile, url=http://169.254.32.119:4000/actuator/logfile), nacosconfig=Endpoint(id=nacosconfig, url=http://169.254.32.119:4000/actuator/nacosconfig), health=Endpoint(id=health, url=http://169.254.32.119:4000/actuator/health), refresh=Endpoint(id=refresh, url=http://169.254.32.119:4000/actuator/refresh), env=Endpoint(id=env, url=http://169.254.32.119:4000/actuator/env), nacosdiscovery=Endpoint(id=nacosdiscovery, url=http://169.254.32.119:4000/actuator/nacosdiscovery), serviceregistry=Endpoint(id=serviceregistry, url=http://169.254.32.119:4000/actuator/serviceregistry), features=Endpoint(id=features, url=http://169.254.32.119:4000/actuator/features), scheduledtasks=Endpoint(id=scheduledtasks, url=http://169.254.32.119:4000/actuator/scheduledtasks), mappings=Endpoint(id=mappings, url=http://169.254.32.119:4000/actuator/mappings), beans=Endpoint(id=beans, url=http://169.254.32.119:4000/actuator/beans), configprops=Endpoint(id=configprops, url=http://169.254.32.119:4000/actuator/configprops), threaddump=Endpoint(id=threaddump, url=http://169.254.32.119:4000/actuator/threaddump), sbom=Endpoint(id=sbom, url=http://169.254.32.119:4000/actuator/sbom), metrics=Endpoint(id=metrics, url=http://169.254.32.119:4000/actuator/metrics), conditions=Endpoint(id=conditions, url=http://169.254.32.119:4000/actuator/conditions), info=Endpoint(id=info, url=http://169.254.32.119:4000/actuator/info)}), buildVersion=null, tags=Tags(values={})) java.util.concurrent.TimeoutException: Did not observe any item or terminal signal within 9000ms in 'log' (and no fallback has been configured) at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.handleTimeout(FluxTimeout.java:296) at reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber.doTimeout(FluxTimeout.java:281) at reactor.core.publisher.FluxTimeout$TimeoutTimeoutSubscriber.onNext(FluxTimeout.java:420) at reactor.core.publisher.FluxOnErrorReturn$ReturnSubscriber.onNext(FluxOnErrorReturn.java:162) at reactor.core.publisher.MonoDelay$MonoDelayRunnable.propagateDelay(MonoDelay.java:270) at reactor.core.publisher.MonoDelay$MonoDelayRunnable.run(MonoDelay.java:285) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.lang.Thread.run(Thread.java:1583) :2025-07-18 15:04:25.487 WARN reactor-http-nio-5 r.n.h.c.HttpClientConnect: [ec305008-48, L:/169.254.32.119:52069 ! R:/169.254.32.119:3000] The connection observed an error reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response :2025-07-18 15:04:25.525 INFO reactor-http-nio-5 d.c.b.a.s.s.StatusUpdater: Couldn't retrieve status for Instance(id=522f7024e859, version=4, registration=Registration(name=pig-auth, managementUrl=http://169.254.32.119:3000/actuator, healthUrl=http://169.254.32.119:3000/actuator/health, serviceUrl=http://169.254.32.119:3000, source=discovery), registered=true, statusInfo=StatusInfo(status=UP, details={nacosConfig={status=UP}, diskSpace={status=UP, details={total=807073214464, free=572620488704, threshold=10485760, path=D:\develop\workCode\seo\., exists=true}}, ping={status=UP}, discoveryComposite={status=UP, components={discoveryClient={status=UP, details={services=[pig-gateway, pig-monitor, pig-quartz, pig-upms-biz, pig-codegen, pig-auth]}}}}, refreshScope={status=UP}, nacosDiscovery={status=UP}, ssl={status=UP, details={validChains=[], invalidChains=[]}}, redis={status=UP, details={version=6.0.20}}}), statusTimestamp=2025-07-18T06:24:07.767408400Z, info=Info(values={}), endpoints=Endpoints(endpoints={sentinel=Endpoint(id=sentinel, url=http://169.254.32.119:3000/actuator/sentinel), caches=Endpoint(id=caches, url=http://169.254.32.119:3000/actuator/caches), loggers=Endpoint(id=loggers, url=http://169.254.32.119:3000/actuator/loggers), logfile=Endpoint(id=logfile, url=http://169.254.32.119:3000/actuator/logfile), nacosconfig=Endpoint(id=nacosconfig, url=http://169.254.32.119:3000/actuator/nacosconfig), health=Endpoint(id=health, url=http://169.254.32.119:3000/actuator/health), refresh=Endpoint(id=refresh, url=http://169.254.32.119:3000/actuator/refresh), env=Endpoint(id=env, url=http://169.254.32.119:3000/actuator/env), nacosdiscovery=Endpoint(id=nacosdiscovery, url=http://169.254.32.119:3000/actuator/nacosdiscovery), serviceregistry=Endpoint(id=serviceregistry, url=http://169.254.32.119:3000/actuator/serviceregistry), features=Endpoint(id=features, url=http://169.254.32.119:3000/actuator/features), scheduledtasks=Endpoint(id=scheduledtasks, url=http://169.254.32.119:3000/actuator/scheduledtasks), mappings=Endpoint(id=mappings, url=http://169.254.32.119:3000/actuator/mappings), beans=Endpoint(id=beans, url=http://169.254.32.119:3000/actuator/beans), configprops=Endpoint(id=configprops, url=http://169.254.32.119:3000/actuator/configprops), threaddump=Endpoint(id=threaddump, url=http://169.254.32.119:3000/actuator/threaddump), sbom=Endpoint(id=sbom, url=http://169.254.32.119:3000/actuator/sbom), metrics=Endpoint(id=metrics, url=http://169.254.32.119:3000/actuator/metrics), conditions=Endpoint(id=conditions, url=http://169.254.32.119:3000/actuator/conditions), info=Endpoint(id=info, url=http://169.254.32.119:3000/actuator/info)}), buildVersion=null, tags=Tags(values={})) org.springframework.web.reactive.function.client.WebClientRequestException: Connection prematurely closed BEFORE response at org.springframework.web.reactive.function.client.ExchangeFunctions$DefaultExchangeFunction.lambda$wrapException$9(ExchangeFunctions.java:137) Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s): *__checkpoint ⇢ Request to GET health [DefaultWebClient] Original Stack Trace: at org.springframework.web.reactive.function.client.ExchangeFunctions$DefaultExchangeFunction.lambda$wrapException$9(ExchangeFunctions.java:137) at reactor.core.publisher.MonoErrorSupplied.subscribe(MonoErrorSupplied.java:55) at reactor.core.publisher.Mono.subscribe(Mono.java:4576) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.MonoNext$NextSubscriber.onError(MonoNext.java:93) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onError(MonoFlatMapMany.java:205) at reactor.core.publisher.SerializedSubscriber.onError(SerializedSubscriber.java:124) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.whenError(FluxRetryWhen.java:229) at reactor.core.publisher.FluxRetryWhen$RetryWhenOtherSubscriber.onError(FluxRetryWhen.java:279) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.maybeOnError(FluxConcatMapNoPrefetch.java:327) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:212) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107) at reactor.core.publisher.SinkManyEmitterProcessor.drain(SinkManyEmitterProcessor.java:476) at reactor.core.publisher.SinkManyEmitterProcessor$EmitterInner.drainParent(SinkManyEmitterProcessor.java:620) at reactor.core.publisher.FluxPublish$PubSubInner.request(FluxPublish.java:874) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:337) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.Operators$DeferredSubscription.request(Operators.java:1742) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onError(FluxRetryWhen.java:196) at reactor.core.publisher.MonoCreate$DefaultMonoSink.error(MonoCreate.java:205) at reactor.netty.http.client.HttpClientConnect$HttpObserver.onUncaughtException(HttpClientConnect.java:417) at reactor.netty.ReactorNetty$CompositeConnectionObserver.onUncaughtException(ReactorNetty.java:715) at reactor.netty.resources.DefaultPooledConnectionProvider$DisposableAcquire.onUncaughtException(DefaultPooledConnectionProvider.java:225) at reactor.netty.resources.DefaultPooledConnectionProvider$PooledConnection.onUncaughtException(DefaultPooledConnectionProvider.java:478) at reactor.netty.http.client.HttpClientOperations.onInboundClose(HttpClientOperations.java:341) at reactor.netty.channel.ChannelOperationsHandler.channelInactive(ChannelOperationsHandler.java:73) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.ChannelInboundHandlerAdapter.channelInactive(ChannelInboundHandlerAdapter.java:81) at io.netty.handler.codec.http.HttpContentDecoder.channelInactive(HttpContentDecoder.java:235) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelInactive(CombinedChannelDuplexHandler.java:418) at io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:412) at io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:377) at io.netty.handler.codec.http.HttpClientCodec$Decoder.channelInactive(HttpClientCodec.java:410) at io.netty.channel.CombinedChannelDuplexHandler.channelInactive(CombinedChannelDuplexHandler.java:221) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1352) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:301) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:850) at io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:811) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:566) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:998) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:1583) Caused by: reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response :2025-07-18 15:58:45.468 WARN reactor-http-nio-5 r.n.h.c.HttpClientConnect: [a1823554-116, L:/169.254.32.119:52070 ! R:/169.254.32.119:3000] The connection observed an error reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response :2025-07-18 15:58:45.468 WARN reactor-http-nio-8 r.n.h.c.HttpClientConnect: [7af31ab3-114, L:/169.254.32.119:52122 ! R:/169.254.32.119:5007] The connection observed an error reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response :2025-07-18 15:58:45.468 WARN reactor-http-nio-4 r.n.h.c.HttpClientConnect: [ac95f24f-179, L:/169.254.32.119:49389 ! R:/169.254.32.119:4000] The connection observed an error reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response :2025-07-18 15:58:45.477 WARN reactor-http-nio-8 d.c.b.a.s.s.InfoUpdater: Couldn't retrieve info for Instance(id=fe788dc64c5c, version=4, registration=Registration(name=pig-quartz, managementUrl=http://169.254.32.119:5007/actuator, healthUrl=http://169.254.32.119:5007/actuator/health, serviceUrl=http://169.254.32.119:5007, source=discovery), registered=true, statusInfo=StatusInfo(status=UP, details={nacosConfig={status=UP}, diskSpace={status=UP, details={total=807073214464, free=572620341248, threshold=10485760, path=D:\develop\workCode\seo\., exists=true}}, ping={status=UP}, discoveryComposite={status=UP, components={discoveryClient={status=UP, details={services=[pig-gateway, pig-monitor, pig-quartz, pig-upms-biz, pig-codegen, pig-auth]}}}}, refreshScope={status=UP}, nacosDiscovery={status=UP}, ssl={status=UP, details={validChains=[], invalidChains=[]}}, db={status=UP, details={database=MySQL, validationQuery=isValid()}}, redis={status=UP, details={version=6.0.20}}}), statusTimestamp=2025-07-18T06:24:15.494885600Z, info=Info(values={}), endpoints=Endpoints(endpoints={sentinel=Endpoint(id=sentinel, url=http://169.254.32.119:5007/actuator/sentinel), caches=Endpoint(id=caches, url=http://169.254.32.119:5007/actuator/caches), loggers=Endpoint(id=loggers, url=http://169.254.32.119:5007/actuator/loggers), logfile=Endpoint(id=logfile, url=http://169.254.32.119:5007/actuator/logfile), nacosconfig=Endpoint(id=nacosconfig, url=http://169.254.32.119:5007/actuator/nacosconfig), health=Endpoint(id=health, url=http://169.254.32.119:5007/actuator/health), quartz=Endpoint(id=quartz, url=http://169.254.32.119:5007/actuator/quartz), refresh=Endpoint(id=refresh, url=http://169.254.32.119:5007/actuator/refresh), env=Endpoint(id=env, url=http://169.254.32.119:5007/actuator/env), nacosdiscovery=Endpoint(id=nacosdiscovery, url=http://169.254.32.119:5007/actuator/nacosdiscovery), serviceregistry=Endpoint(id=serviceregistry, url=http://169.254.32.119:5007/actuator/serviceregistry), features=Endpoint(id=features, url=http://169.254.32.119:5007/actuator/features), scheduledtasks=Endpoint(id=scheduledtasks, url=http://169.254.32.119:5007/actuator/scheduledtasks), mappings=Endpoint(id=mappings, url=http://169.254.32.119:5007/actuator/mappings), beans=Endpoint(id=beans, url=http://169.254.32.119:5007/actuator/beans), configprops=Endpoint(id=configprops, url=http://169.254.32.119:5007/actuator/configprops), threaddump=Endpoint(id=threaddump, url=http://169.254.32.119:5007/actuator/threaddump), sbom=Endpoint(id=sbom, url=http://169.254.32.119:5007/actuator/sbom), metrics=Endpoint(id=metrics, url=http://169.254.32.119:5007/actuator/metrics), conditions=Endpoint(id=conditions, url=http://169.254.32.119:5007/actuator/conditions), info=Endpoint(id=info, url=http://169.254.32.119:5007/actuator/info)}), buildVersion=null, tags=Tags(values={})) org.springframework.web.reactive.function.client.WebClientRequestException: Connection prematurely closed BEFORE response at org.springframework.web.reactive.function.client.ExchangeFunctions$DefaultExchangeFunction.lambda$wrapException$9(ExchangeFunctions.java:137) Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s): *__checkpoint ⇢ Request to GET info [DefaultWebClient] Original Stack Trace: at org.springframework.web.reactive.function.client.ExchangeFunctions$DefaultExchangeFunction.lambda$wrapException$9(ExchangeFunctions.java:137) at reactor.core.publisher.MonoErrorSupplied.subscribe(MonoErrorSupplied.java:55) at reactor.core.publisher.Mono.subscribe(Mono.java:4576) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.MonoNext$NextSubscriber.onError(MonoNext.java:93) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onError(MonoFlatMapMany.java:205) at reactor.core.publisher.SerializedSubscriber.onError(SerializedSubscriber.java:124) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.whenError(FluxRetryWhen.java:229) at reactor.core.publisher.FluxRetryWhen$RetryWhenOtherSubscriber.onError(FluxRetryWhen.java:279) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.maybeOnError(FluxConcatMapNoPrefetch.java:327) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:212) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107) at reactor.core.publisher.SinkManyEmitterProcessor.drain(SinkManyEmitterProcessor.java:476) at reactor.core.publisher.SinkManyEmitterProcessor$EmitterInner.drainParent(SinkManyEmitterProcessor.java:620) at reactor.core.publisher.FluxPublish$PubSubInner.request(FluxPublish.java:874) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:337) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.Operators$DeferredSubscription.request(Operators.java:1742) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onError(FluxRetryWhen.java:196) at reactor.core.publisher.MonoCreate$DefaultMonoSink.error(MonoCreate.java:205) at reactor.netty.http.client.HttpClientConnect$HttpObserver.onUncaughtException(HttpClientConnect.java:417) at reactor.netty.ReactorNetty$CompositeConnectionObserver.onUncaughtException(ReactorNetty.java:715) at reactor.netty.resources.DefaultPooledConnectionProvider$DisposableAcquire.onUncaughtException(DefaultPooledConnectionProvider.java:225) at reactor.netty.resources.DefaultPooledConnectionProvider$PooledConnection.onUncaughtException(DefaultPooledConnectionProvider.java:478) at reactor.netty.http.client.HttpClientOperations.onInboundClose(HttpClientOperations.java:341) at reactor.netty.channel.ChannelOperationsHandler.channelInactive(ChannelOperationsHandler.java:73) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.ChannelInboundHandlerAdapter.channelInactive(ChannelInboundHandlerAdapter.java:81) at io.netty.handler.codec.http.HttpContentDecoder.channelInactive(HttpContentDecoder.java:235) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelInactive(CombinedChannelDuplexHandler.java:418) at io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:412) at io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:377) at io.netty.handler.codec.http.HttpClientCodec$Decoder.channelInactive(HttpClientCodec.java:410) at io.netty.channel.CombinedChannelDuplexHandler.channelInactive(CombinedChannelDuplexHandler.java:221) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1352) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:301) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:850) at io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:811) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:566) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:998) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:1583) Caused by: reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response :2025-07-18 15:58:45.477 WARN reactor-http-nio-4 d.c.b.a.s.s.InfoUpdater: Couldn't retrieve info for Instance(id=e1f621ea21bb, version=4, registration=Registration(name=pig-upms-biz, managementUrl=http://169.254.32.119:4000/actuator, healthUrl=http://169.254.32.119:4000/actuator/health, serviceUrl=http://169.254.32.119:4000, source=discovery), registered=true, statusInfo=StatusInfo(status=UP, details={nacosConfig={status=UP}, diskSpace={status=UP, details={total=807073214464, free=572620488704, threshold=10485760, path=D:\develop\workCode\seo\., exists=true}}, ping={status=UP}, discoveryComposite={status=UP, components={discoveryClient={status=UP, details={services=[pig-gateway, pig-monitor, pig-quartz, pig-upms-biz, pig-codegen, pig-auth]}}}}, refreshScope={status=UP}, nacosDiscovery={status=UP}, ssl={status=UP, details={validChains=[], invalidChains=[]}}, db={status=UP, details={database=MySQL, validationQuery=isValid()}}, redis={status=UP, details={version=6.0.20}}}), statusTimestamp=2025-07-18T06:24:10.065814200Z, info=Info(values={}), endpoints=Endpoints(endpoints={sentinel=Endpoint(id=sentinel, url=http://169.254.32.119:4000/actuator/sentinel), caches=Endpoint(id=caches, url=http://169.254.32.119:4000/actuator/caches), loggers=Endpoint(id=loggers, url=http://169.254.32.119:4000/actuator/loggers), logfile=Endpoint(id=logfile, url=http://169.254.32.119:4000/actuator/logfile), nacosconfig=Endpoint(id=nacosconfig, url=http://169.254.32.119:4000/actuator/nacosconfig), health=Endpoint(id=health, url=http://169.254.32.119:4000/actuator/health), refresh=Endpoint(id=refresh, url=http://169.254.32.119:4000/actuator/refresh), env=Endpoint(id=env, url=http://169.254.32.119:4000/actuator/env), nacosdiscovery=Endpoint(id=nacosdiscovery, url=http://169.254.32.119:4000/actuator/nacosdiscovery), serviceregistry=Endpoint(id=serviceregistry, url=http://169.254.32.119:4000/actuator/serviceregistry), features=Endpoint(id=features, url=http://169.254.32.119:4000/actuator/features), scheduledtasks=Endpoint(id=scheduledtasks, url=http://169.254.32.119:4000/actuator/scheduledtasks), mappings=Endpoint(id=mappings, url=http://169.254.32.119:4000/actuator/mappings), beans=Endpoint(id=beans, url=http://169.254.32.119:4000/actuator/beans), configprops=Endpoint(id=configprops, url=http://169.254.32.119:4000/actuator/configprops), threaddump=Endpoint(id=threaddump, url=http://169.254.32.119:4000/actuator/threaddump), sbom=Endpoint(id=sbom, url=http://169.254.32.119:4000/actuator/sbom), metrics=Endpoint(id=metrics, url=http://169.254.32.119:4000/actuator/metrics), conditions=Endpoint(id=conditions, url=http://169.254.32.119:4000/actuator/conditions), info=Endpoint(id=info, url=http://169.254.32.119:4000/actuator/info)}), buildVersion=null, tags=Tags(values={})) org.springframework.web.reactive.function.client.WebClientRequestException: Connection prematurely closed BEFORE response at org.springframework.web.reactive.function.client.ExchangeFunctions$DefaultExchangeFunction.lambda$wrapException$9(ExchangeFunctions.java:137) Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s): *__checkpoint ⇢ Request to GET info [DefaultWebClient] Original Stack Trace: at org.springframework.web.reactive.function.client.ExchangeFunctions$DefaultExchangeFunction.lambda$wrapException$9(ExchangeFunctions.java:137) at reactor.core.publisher.MonoErrorSupplied.subscribe(MonoErrorSupplied.java:55) at reactor.core.publisher.Mono.subscribe(Mono.java:4576) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.MonoNext$NextSubscriber.onError(MonoNext.java:93) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onError(MonoFlatMapMany.java:205) at reactor.core.publisher.SerializedSubscriber.onError(SerializedSubscriber.java:124) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.whenError(FluxRetryWhen.java:229) at reactor.core.publisher.FluxRetryWhen$RetryWhenOtherSubscriber.onError(FluxRetryWhen.java:279) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.maybeOnError(FluxConcatMapNoPrefetch.java:327) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:212) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107) at reactor.core.publisher.SinkManyEmitterProcessor.drain(SinkManyEmitterProcessor.java:476) at reactor.core.publisher.SinkManyEmitterProcessor$EmitterInner.drainParent(SinkManyEmitterProcessor.java:620) at reactor.core.publisher.FluxPublish$PubSubInner.request(FluxPublish.java:874) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:337) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.Operators$DeferredSubscription.request(Operators.java:1742) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onError(FluxRetryWhen.java:196) at reactor.core.publisher.MonoCreate$DefaultMonoSink.error(MonoCreate.java:205) at reactor.netty.http.client.HttpClientConnect$HttpObserver.onUncaughtException(HttpClientConnect.java:417) at reactor.netty.ReactorNetty$CompositeConnectionObserver.onUncaughtException(ReactorNetty.java:715) at reactor.netty.resources.DefaultPooledConnectionProvider$DisposableAcquire.onUncaughtException(DefaultPooledConnectionProvider.java:225) at reactor.netty.resources.DefaultPooledConnectionProvider$PooledConnection.onUncaughtException(DefaultPooledConnectionProvider.java:478) at reactor.netty.http.client.HttpClientOperations.onInboundClose(HttpClientOperations.java:341) at reactor.netty.channel.ChannelOperationsHandler.channelInactive(ChannelOperationsHandler.java:73) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.ChannelInboundHandlerAdapter.channelInactive(ChannelInboundHandlerAdapter.java:81) at io.netty.handler.codec.http.HttpContentDecoder.channelInactive(HttpContentDecoder.java:235) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelInactive(CombinedChannelDuplexHandler.java:418) at io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:412) at io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:377) at io.netty.handler.codec.http.HttpClientCodec$Decoder.channelInactive(HttpClientCodec.java:410) at io.netty.channel.CombinedChannelDuplexHandler.channelInactive(CombinedChannelDuplexHandler.java:221) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1352) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:301) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:850) at io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:811) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:566) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:998) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:1583) Caused by: reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response :2025-07-18 15:58:45.477 INFO reactor-http-nio-5 d.c.b.a.s.s.StatusUpdater: Couldn't retrieve status for Instance(id=522f7024e859, version=6, registration=Registration(name=pig-auth, managementUrl=http://169.254.32.119:3000/actuator, healthUrl=http://169.254.32.119:3000/actuator/health, serviceUrl=http://169.254.32.119:3000, source=discovery), registered=true, statusInfo=StatusInfo(status=UP, details={nacosConfig={status=UP}, diskSpace={status=UP, details={total=807073214464, free=571393486848, threshold=10485760, path=D:\develop\workCode\seo\., exists=true}}, ping={status=UP}, discoveryComposite={status=UP, components={discoveryClient={status=UP, details={services=[pig-gateway, pig-monitor, pig-quartz, pig-upms-biz, pig-codegen, pig-auth]}}}}, refreshScope={status=UP}, nacosDiscovery={status=UP}, ssl={status=UP, details={validChains=[], invalidChains=[]}}, redis={status=UP, details={version=6.0.20}}}), statusTimestamp=2025-07-18T07:04:45.364114Z, info=Info(values={}), endpoints=Endpoints(endpoints={sentinel=Endpoint(id=sentinel, url=http://169.254.32.119:3000/actuator/sentinel), caches=Endpoint(id=caches, url=http://169.254.32.119:3000/actuator/caches), loggers=Endpoint(id=loggers, url=http://169.254.32.119:3000/actuator/loggers), logfile=Endpoint(id=logfile, url=http://169.254.32.119:3000/actuator/logfile), nacosconfig=Endpoint(id=nacosconfig, url=http://169.254.32.119:3000/actuator/nacosconfig), health=Endpoint(id=health, url=http://169.254.32.119:3000/actuator/health), refresh=Endpoint(id=refresh, url=http://169.254.32.119:3000/actuator/refresh), env=Endpoint(id=env, url=http://169.254.32.119:3000/actuator/env), nacosdiscovery=Endpoint(id=nacosdiscovery, url=http://169.254.32.119:3000/actuator/nacosdiscovery), serviceregistry=Endpoint(id=serviceregistry, url=http://169.254.32.119:3000/actuator/serviceregistry), features=Endpoint(id=features, url=http://169.254.32.119:3000/actuator/features), scheduledtasks=Endpoint(id=scheduledtasks, url=http://169.254.32.119:3000/actuator/scheduledtasks), mappings=Endpoint(id=mappings, url=http://169.254.32.119:3000/actuator/mappings), beans=Endpoint(id=beans, url=http://169.254.32.119:3000/actuator/beans), configprops=Endpoint(id=configprops, url=http://169.254.32.119:3000/actuator/configprops), threaddump=Endpoint(id=threaddump, url=http://169.254.32.119:3000/actuator/threaddump), sbom=Endpoint(id=sbom, url=http://169.254.32.119:3000/actuator/sbom), metrics=Endpoint(id=metrics, url=http://169.254.32.119:3000/actuator/metrics), conditions=Endpoint(id=conditions, url=http://169.254.32.119:3000/actuator/conditions), info=Endpoint(id=info, url=http://169.254.32.119:3000/actuator/info)}), buildVersion=null, tags=Tags(values={})) org.springframework.web.reactive.function.client.WebClientRequestException: Connection prematurely closed BEFORE response at org.springframework.web.reactive.function.client.ExchangeFunctions$DefaultExchangeFunction.lambda$wrapException$9(ExchangeFunctions.java:137) Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: Error has been observed at the following site(s): *__checkpoint ⇢ Request to GET health [DefaultWebClient] Original Stack Trace: at org.springframework.web.reactive.function.client.ExchangeFunctions$DefaultExchangeFunction.lambda$wrapException$9(ExchangeFunctions.java:137) at reactor.core.publisher.MonoErrorSupplied.subscribe(MonoErrorSupplied.java:55) at reactor.core.publisher.Mono.subscribe(Mono.java:4576) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.MonoNext$NextSubscriber.onError(MonoNext.java:93) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onError(MonoFlatMapMany.java:205) at reactor.core.publisher.SerializedSubscriber.onError(SerializedSubscriber.java:124) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.whenError(FluxRetryWhen.java:229) at reactor.core.publisher.FluxRetryWhen$RetryWhenOtherSubscriber.onError(FluxRetryWhen.java:279) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.maybeOnError(FluxConcatMapNoPrefetch.java:327) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:212) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107) at reactor.core.publisher.SinkManyEmitterProcessor.drain(SinkManyEmitterProcessor.java:476) at reactor.core.publisher.SinkManyEmitterProcessor$EmitterInner.drainParent(SinkManyEmitterProcessor.java:620) at reactor.core.publisher.FluxPublish$PubSubInner.request(FluxPublish.java:874) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:337) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.Operators$DeferredSubscription.request(Operators.java:1742) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onError(FluxRetryWhen.java:196) at reactor.core.publisher.MonoCreate$DefaultMonoSink.error(MonoCreate.java:205) at reactor.netty.http.client.HttpClientConnect$HttpObserver.onUncaughtException(HttpClientConnect.java:417) at reactor.netty.ReactorNetty$CompositeConnectionObserver.onUncaughtException(ReactorNetty.java:715) at reactor.netty.resources.DefaultPooledConnectionProvider$DisposableAcquire.onUncaughtException(DefaultPooledConnectionProvider.java:225) at reactor.netty.resources.DefaultPooledConnectionProvider$PooledConnection.onUncaughtException(DefaultPooledConnectionProvider.java:478) at reactor.netty.http.client.HttpClientOperations.onInboundClose(HttpClientOperations.java:341) at reactor.netty.channel.ChannelOperationsHandler.channelInactive(ChannelOperationsHandler.java:73) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.ChannelInboundHandlerAdapter.channelInactive(ChannelInboundHandlerAdapter.java:81) at io.netty.handler.codec.http.HttpContentDecoder.channelInactive(HttpContentDecoder.java:235) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelInactive(CombinedChannelDuplexHandler.java:418) at io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:412) at io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:377) at io.netty.handler.codec.http.HttpClientCodec$Decoder.channelInactive(HttpClientCodec.java:410) at io.netty.channel.CombinedChannelDuplexHandler.channelInactive(CombinedChannelDuplexHandler.java:221) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:303) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:274) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1352) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:301) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:281) at io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:850) at io.netty.channel.AbstractChannel$AbstractUnsafe$7.run(AbstractChannel.java:811) at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:566) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:998) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:1583) Caused by: reactor.netty.http.client.PrematureCloseException: Connection prematurely closed BEFORE response