11111

cloud-etl-common/src/main/java/com/muyu/etl/common/domain/EtlRule.java

@@ -0,0 +1,81 @@
+package com.muyu.etl.common.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.muyu.common.core.web.domain.BaseEntity;
+import com.muyu.etl.common.domain.req.EtlRuleAddReq;
+import com.muyu.etl.common.domain.req.EtlRuleUpdReq;
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.util.function.Supplier;
+
+/**
+ * @Author：张承志
+ * @Package：com.muyu.damain
+ * @Project：cloud-etl
+ * @name：Rule
+ * @Date：2024/8/21 11:33
+ */
+
+@Data
+@SuperBuilder
+@AllArgsConstructor
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = true)
+@TableName(value = "etl_rule",autoResultMap = true)
+public class EtlRule extends BaseEntity {
+
+    /**
+     *主键
+     */
+    @TableId(value = "id" , type = IdType.AUTO)
+    private Long id ;
+    /** 规则名称 */
+
+    private String name ;
+    /** 规则类型 */
+
+    private String type ;
+    /** 全限定类名 */
+
+    private String fullClassName ;
+
+    /** 规则说明 */
+    private String explain ;
+
+    /** 是否公开 0已激活 1未激活 */
+    private String open ;
+
+
+    /** 状态 0正常 1停用 */
+    private String status ;
+
+
+    public static EtlRule updBuild(EtlRuleUpdReq etlRule, Supplier<Long> longSupplier){
+
+      return EtlRule.builder().id(longSupplier.get())
+                 .open(etlRule.getOpen())
+                 .name(etlRule.getName())
+                 .status(etlRule.getStatus())
+                 .type(etlRule.getType())
+                 .explain(etlRule.getExplain())
+                 .remark(etlRule.getRemark())
+                 .build();
+
+    }
+
+    public static EtlRule addBuild(EtlRuleAddReq etlRule){
+
+        return EtlRule.builder()
+                .open(etlRule.getOpen())
+                .name(etlRule.getName())
+                .status(etlRule.getStatus())
+                .type(etlRule.getType())
+                .explain(etlRule.getExplain())
+                .remark(etlRule.getRemark())
+                .build();
+
+    }
+}

cloud-etl-common/src/main/java/com/muyu/etl/common/domain/req/EtlRuleAddReq.java

@@ -0,0 +1,48 @@
+package com.muyu.etl.common.domain.req;
+
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+/**
+ * @Author：张承志
+ * @Package：com.muyu.etl.common.domain.req
+ * @Project：cloud-etl
+ * @name：EtlRuleAddReq
+ * @Date：2024/8/21 23:49
+ */
+@Data
+@SuperBuilder
+@NoArgsConstructor
+@AllArgsConstructor
+@Tag(name = "客户端规则添加请求对象")
+public class EtlRuleAddReq {
+
+    /** 规则名称 */
+    private String name ;
+    /** 规则类型 */
+
+    private String type ;
+    /** 全限定类名 */
+
+    private String fullClassName ;
+
+    /** 规则说明 */
+    private String explain ;
+
+    /** 是否公开 0已激活 1未激活 */
+    private String open ;
+
+
+    /** 状态 0正常 1停用 */
+    private String status ;
+
+    /**
+     * 备注
+     */
+
+    private String remark;
+
+}

cloud-etl-common/src/main/java/com/muyu/etl/common/domain/req/EtlRuleListReq.java

@@ -0,0 +1,39 @@
+package com.muyu.etl.common.domain.req;
+
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+/**
+ * @Author：张承志
+ * @Package：com.muyu.etl.common.domain.req
+ * @Project：cloud-etl
+ * @name：EtlRuleListReq
+ * @Date：2024/8/21 21:42
+ */
+@Data
+@SuperBuilder
+@NoArgsConstructor
+@AllArgsConstructor
+@Tag(name = "客户端规则列表请求对象")
+public class EtlRuleListReq {
+
+
+    /** 数据来源类型 */
+    private String type ;
+    /** 数据来源名称 */
+    private String name ;
+
+    /** 是否公开 0已激活 1未激活 */
+    private String open ;
+
+
+    /** 状态 0正常 1停用 */
+    private String status ;
+
+
+
+
+}

cloud-etl-common/src/main/java/com/muyu/etl/common/domain/req/EtlRuleUpdReq.java

@@ -0,0 +1,50 @@
+package com.muyu.etl.common.domain.req;
+
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+/**
+ * @Author：张承志
+ * @Package：com.muyu.etl.common.domain.req
+ * @Project：cloud-etl
+ * @name：EtlRuleUpdReq
+ * @Date：2024/8/21 23:48
+ */
+@Data
+@SuperBuilder
+@NoArgsConstructor
+@AllArgsConstructor
+@Tag(name = "客户端规则修改请求对象")
+public class EtlRuleUpdReq {
+
+
+    /** 规则名称 */
+    private String name ;
+    /** 规则类型 */
+
+    private String type ;
+    /** 全限定类名 */
+
+    private String fullClassName ;
+
+    /** 规则说明 */
+    private String explain ;
+
+    /** 是否公开 0已激活 1未激活 */
+    private String open ;
+
+
+    /** 状态 0正常 1停用 */
+    private String status ;
+
+/**
+ * 备注
+ */
+
+private String remark;
+
+
+}

cloud-etl-common/src/main/java/com/muyu/etl/common/domain/resp/EtlRuleResp.java

@@ -0,0 +1,77 @@
+package com.muyu.etl.common.domain.resp;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.muyu.common.core.annotation.Excel;
+import com.muyu.etl.common.domain.EtlRule;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/**
+ * @Author：张承志
+ * @Package：com.muyu.etl.common.domain.resp
+ * @Project：cloud-etl
+ * @name：EtlRuleResp
+ * @Date：2024/8/21 21:57
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+@Tag(name = "规则信息相应对象", description = "负责规则信息查询的响应结果")
+public class EtlRuleResp {
+
+
+    /**
+     *主键
+     */
+    @TableId(value = "id" , type = IdType.AUTO)
+    private Long id ;
+
+    /** 规则名称 */
+
+    private String name ;
+    /** 规则类型 */
+
+    private String type ;
+    /** 全限定类名 */
+
+    private String fullClassName ;
+
+    /** 规则说明 */
+    private String explain ;
+
+
+    @Schema(description = "创建人", defaultValue = "muyu", type = "String")
+    private String createBy;
+
+
+
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    @Schema(description = "创建时间", defaultValue = "2024-8-1 0:22:36", type = "Date")
+    private Date createTime;
+
+public static EtlRuleResp  etlRuleRespBuilder(EtlRule etlRule){
+
+    return  EtlRuleResp.builder()
+            .id(etlRule.getId())
+            .type(etlRule.getType())
+            .name(etlRule.getName())
+            .createBy(etlRule.getCreateBy())
+            .createTime(etlRule.getCreateTime()).build();
+
+
+
+}
+
+}

cloud-etl-server/src/main/java/com/muyu/etl/EtlServiceApplication.java

@@ -0,0 +1,24 @@
+package com.muyu.etl;
+
+import com.muyu.common.security.annotation.EnableCustomConfig;
+import com.muyu.common.security.annotation.EnableMyFeignClients;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @Author：张承志
+ * @Package：com.muyu.etl
+ * @Project：cloud-etl
+ * @name：EtlServiceApplication
+ * @Date：2024/8/21 14:07
+ */
+@Log4j2
+@EnableCustomConfig
+@EnableMyFeignClients
+@SpringBootApplication
+public class EtlServiceApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(EtlServiceApplication.class);
+    }
+}

cloud-etl-server/src/main/java/com/muyu/etl/controller/EtlRuleController.java

@@ -0,0 +1,110 @@
+package com.muyu.etl.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.dtflys.forest.annotation.Post;
+import com.muyu.common.core.domain.Result;
+import com.muyu.etl.common.domain.EtlRule;
+import com.muyu.etl.common.domain.req.EtlRuleAddReq;
+import com.muyu.etl.common.domain.req.EtlRuleListReq;
+import com.muyu.etl.common.domain.req.EtlRuleUpdReq;
+import com.muyu.etl.common.domain.resp.EtlRuleResp;
+import com.muyu.etl.service.EtlRuleService;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.PageImpl;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * @Author：张承志
+ * @Package：com.muyu.etl.controller
+ * @Project：cloud-etl
+ * @name：EtlRuleController
+ * @Date：2024/8/21 14:17
+ */
+@Log4j2
+@RestController
+@RequestMapping("/etlRule")
+@RequiredArgsConstructor
+@Tag(name = "etl规则控制层", description = "进行etl规则管理,查看等相关操作")
+public class EtlRuleController {
+
+    @Autowired
+    private EtlRuleService etlRuleService;
+
+    /**
+     * 通过ID查询单条数据
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    @GetMapping("/{id}")
+    public Result<EtlRule> queryById(@PathVariable("id") int id){
+        EtlRule etlRule = etlRuleService.queryById(id);
+        return Result.success(etlRule);
+    }
+
+
+    @PostMapping("/List")
+    public Result<List<EtlRuleResp>>  selectList(@Validated @RequestBody EtlRuleListReq req){
+
+     List<EtlRuleResp> list = etlRuleService.selectList(req);
+
+        return Result.success(list);
+    }
+
+
+    /**
+     * 新增数据
+     *
+     * @param etlRule 实例对象
+     * @return 实例对象
+     */
+
+    @PostMapping
+    public Result<EtlRule> add(@RequestBody EtlRuleAddReq etlRule){
+        etlRuleService.save(EtlRule.addBuild(etlRule));
+        return Result.success();
+    }
+
+    /**
+     * 更新数据
+     *
+     * @param etlRule 实例对象
+     * @return 实例对象
+     */
+
+    @PutMapping("/{id}")
+    public Result<EtlRule> edit(@PathVariable("id") Long  id, @RequestBody @Validated EtlRuleUpdReq etlRule){
+        etlRuleService.updateById(EtlRule.updBuild(etlRule,()->id));
+        return Result.success();
+    }
+
+    /**
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @DeleteMapping
+    public Result<Boolean> deleteById(int id){
+        etlRuleService.deleteById(id);
+        return Result.success();
+    }
+
+
+
+
+
+}
+
+
+
+
+
+

cloud-etl-server/src/main/java/com/muyu/etl/mapper/EtlRuleMapper.java

@@ -0,0 +1,33 @@
+package com.muyu.etl.mapper;
+
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Constants;
+import com.muyu.etl.common.domain.EtlRule;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+/**
+ * @Author：张承志
+ * @Package：com.muyu.etl.mapper
+ * @Project：cloud-etl
+ * @name：EtlRuleMapper
+ * @Date：2024/8/21 14:22
+ */
+@Mapper
+public interface EtlRuleMapper extends BaseMapper<EtlRule> {
+
+    /**
+     * 分页查询指定行数据
+     *
+     * @param page 分页参数
+     * @param wrapper 动态查询条件
+     * @return 分页对象列表
+     */
+    @Select("SELECT * FROM etl_rule")
+    IPage<EtlRule> selectByPage(IPage<EtlRule> page , @Param(Constants.WRAPPER) Wrapper<EtlRule> wrapper);
+
+
+}

cloud-etl-server/src/main/java/com/muyu/etl/service/EtlRuleService.java

@@ -0,0 +1,44 @@
+package com.muyu.etl.service;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.muyu.etl.common.domain.EtlRule;
+import com.muyu.etl.common.domain.req.EtlRuleListReq;
+import com.muyu.etl.common.domain.resp.EtlRuleResp;
+
+import java.util.List;
+
+/**
+ * @Author：张承志
+ * @Package：com.muyu.etl.service
+ * @Project：cloud-etl
+ * @name：EtlRuleService
+ * @Date：2024/8/21 14:21
+ */
+public interface EtlRuleService extends IService<EtlRule> {
+
+    /**
+     * 通过ID查询单条数据
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    EtlRule queryById(int id);
+
+
+    /**
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    boolean deleteById(int id);
+
+    /**
+     * 条件查询列表
+     * @param req
+     * @return
+     */
+
+    List<EtlRuleResp> selectList(EtlRuleListReq req);
+}

cloud-etl-server/src/main/java/com/muyu/etl/service/impl/EtlRuleServiceImpl.java

@@ -0,0 +1,97 @@
+package com.muyu.etl.service.impl;
+
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.muyu.common.core.utils.StringUtils;
+import com.muyu.etl.common.domain.EtlRule;
+import com.muyu.etl.common.domain.req.EtlRuleListReq;
+import com.muyu.etl.common.domain.resp.EtlRuleResp;
+import com.muyu.etl.mapper.EtlRuleMapper;
+import com.muyu.etl.service.EtlRuleService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Author：张承志
+ * @Package：com.muyu.etl.service.impl
+ * @Project：cloud-etl
+ * @name：EtlRuleServiceImpl
+ * @Date：2024/8/21 14:22
+ */
+@Service
+public class EtlRuleServiceImpl extends ServiceImpl<EtlRuleMapper, EtlRule>  implements EtlRuleService {
+
+    @Autowired
+    private EtlRuleMapper etlRuleMapper;
+
+    /**
+     * 通过ID查询单条数据
+     *
+     * @param id 主键
+     * @return 实例对象
+     */
+    @Override
+    public EtlRule queryById(int id){
+        return etlRuleMapper.selectById(id);
+    }
+
+
+
+    /**
+     * 通过主键删除数据
+     *
+     * @param id 主键
+     * @return 是否成功
+     */
+    @Override
+    public boolean deleteById(int id){
+        int total = etlRuleMapper.deleteById(id);
+        return total > 0;
+    }
+
+    @Override
+    public List<EtlRuleResp> selectList(EtlRuleListReq req) {
+
+        LambdaQueryWrapper<EtlRule> queryWrapper = new LambdaQueryWrapper<>();
+
+        queryWrapper.like(StringUtils.isNotEmpty(req.getName()),EtlRule::getName,req.getName());
+
+        queryWrapper.eq(
+          StringUtils.isNotEmpty(req.getStatus()),EtlRule::getStatus,req.getStatus()
+        );
+        queryWrapper.eq(
+                StringUtils.isNotEmpty(req.getOpen()),EtlRule::getOpen,req.getOpen()
+        );
+
+        queryWrapper.eq(
+                StringUtils.isNotEmpty(req.getType()),EtlRule::getType,req.getType()
+        );
+
+        List<EtlRule> etlRuleList = this.list(queryWrapper);
+
+        List<EtlRuleResp> respList = etlRuleList.stream()
+                .map(etlRule -> EtlRuleResp.etlRuleRespBuilder(etlRule)).toList();
+
+
+        return respList;
+    }
+
+
+
+
+
+
+
+
+
+
+
+
+
+}

logs/cloud-pay/info.log

@@ -0,0 +1,428 @@
+16:25:03.390 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+16:32:05.513 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+16:32:07.077 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+16:32:07.371 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+16:32:07.371 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+16:32:07.435 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+16:32:07.705 [main] INFO  c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
+16:32:08.205 [main] INFO  c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
+16:32:13.895 [main] INFO  c.m.c.r.RabbitConfig - [init,26] - rabbit启动成功
+16:32:14.217 [main] INFO  c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
+16:32:16.338 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-no-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@5319f982[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
+16:32:16.338 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-one-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@4ed74b13[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
+16:32:16.514 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,82] - >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999
+16:32:17.530 [main] INFO  c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
+16:32:17.532 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
+16:32:17.532 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
+16:32:17.538 [main] INFO  c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
+16:32:17.550 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
+16:32:17.550 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
+16:32:17.823 [main] INFO  c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 8eff040f-c43f-4141-94da-2b7b7002c3b8
+16:32:17.826 [main] INFO  c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->8eff040f-c43f-4141-94da-2b7b7002c3b8
+16:32:17.826 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8eff040f-c43f-4141-94da-2b7b7002c3b8] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
+16:32:17.826 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8eff040f-c43f-4141-94da-2b7b7002c3b8] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
+16:32:17.827 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8eff040f-c43f-4141-94da-2b7b7002c3b8] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
+16:32:17.827 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8eff040f-c43f-4141-94da-2b7b7002c3b8] Try to connect to server on start up, server: {serverIp = '12.2.0.252', server main port = 8848}
+16:32:17.828 [main] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:12.2.0.252 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+16:32:18.190 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8eff040f-c43f-4141-94da-2b7b7002c3b8] Success to connect to server [12.2.0.252:8848] on start up, connectionId = 1724229138627_12.2.0.3_63264
+16:32:18.191 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8eff040f-c43f-4141-94da-2b7b7002c3b8] Notify connected event to listeners.
+16:32:18.191 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8eff040f-c43f-4141-94da-2b7b7002c3b8] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
+16:32:18.192 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.client.naming - [onConnected,90] - Grpc connection connect
+16:32:18.192 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8eff040f-c43f-4141-94da-2b7b7002c3b8] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$650/0x00000211cc550678
+16:32:18.195 [main] INFO  c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] muyu-cloud registering service cloud-etl with instance Instance{instanceId='null', ip='192.168.134.140', port=9701, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:9220:d890:efbb:88c6:6333:c439], preserved.register.source=SPRING_CLOUD}}
+16:32:18.329 [main] INFO  c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl 192.168.134.140:9701 register finished
+16:32:19.466 [main] INFO  c.m.e.EtlServiceApplication - [logStarted,56] - Started EtlServiceApplication in 18.931 seconds (process running for 19.374)
+16:32:19.473 [main] INFO  c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis 
+16:32:19.473 [main] INFO  c.a.n.c.c.i.CacheData - [<clinit>,99] - nacos.cache.data.init.snapshot = true 
+16:32:19.474 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl+DEFAULT_GROUP+muyu-cloud
+16:32:19.478 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl, group=DEFAULT_GROUP, cnt=1
+16:32:19.478 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl, group=DEFAULT_GROUP
+16:32:19.479 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-dev.yml+DEFAULT_GROUP+muyu-cloud
+16:32:19.479 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP, cnt=1
+16:32:19.479 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP
+16:32:19.479 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl.yml+DEFAULT_GROUP+muyu-cloud
+16:32:19.479 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl.yml, group=DEFAULT_GROUP, cnt=1
+16:32:19.479 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl.yml, group=DEFAULT_GROUP
+16:32:19.966 [RMI TCP Connection(3)-192.168.134.140] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet'
+16:40:09.497 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
+16:40:09.558 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,87] - >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://192.168.134.140:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null]
+16:40:09.559 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy.
+16:40:09.559 [SpringApplicationShutdownHook] INFO  c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
+16:40:09.560 [xxl-job, executor JobLogFileCleanThread] INFO  c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
+16:40:09.561 [xxl-job, executor TriggerCallbackThread] INFO  c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
+16:40:09.561 [Thread-11] INFO  c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
+16:40:09.576 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now...
+16:40:09.576 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] muyu-cloud deregistering service cloud-etl with instance: Instance{instanceId='null', ip='192.168.134.140', port=9701, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}}
+16:40:09.658 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished.
+16:40:09.661 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin
+16:40:09.661 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin
+16:40:09.663 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop
+16:40:09.663 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop
+16:40:09.663 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin
+16:40:09.664 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin
+16:40:09.664 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop
+16:40:09.664 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin
+16:40:09.664 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop
+16:40:09.664 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin
+16:40:09.664 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop
+16:40:09.664 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for  uuid->8eff040f-c43f-4141-94da-2b7b7002c3b8
+16:40:09.665 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@d519209[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 156]
+16:40:09.665 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown
+16:40:09.665 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@99a3d17[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0]
+16:40:09.665 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [closeConnection,584] - Close current connection 1724229138627_12.2.0.3_63264
+16:40:09.667 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@29587330[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 99]
+16:40:09.667 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client  for uuid ->8eff040f-c43f-4141-94da-2b7b7002c3b8
+16:40:09.668 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped
+16:40:09.668 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed
+16:40:09.668 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop
+16:40:09.669 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+16:40:09.669 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+16:40:17.846 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+16:40:19.141 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+16:40:19.400 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+16:40:19.400 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+16:40:19.452 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+16:40:19.697 [main] INFO  c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
+16:40:20.140 [main] INFO  c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
+16:40:23.680 [main] INFO  c.m.c.r.RabbitConfig - [init,26] - rabbit启动成功
+16:40:23.908 [main] INFO  c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
+16:40:25.870 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-no-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@2fe26f79[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
+16:40:25.870 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-one-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@11069bdd[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
+16:40:26.039 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,82] - >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999
+16:40:27.061 [main] INFO  c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
+16:40:27.062 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
+16:40:27.062 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
+16:40:27.067 [main] INFO  c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
+16:40:27.070 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
+16:40:27.070 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
+16:40:27.249 [main] INFO  c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 8d13aad9-d3a7-4f6a-922c-6805f43906dc
+16:40:27.250 [main] INFO  c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->8d13aad9-d3a7-4f6a-922c-6805f43906dc
+16:40:27.251 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d13aad9-d3a7-4f6a-922c-6805f43906dc] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
+16:40:27.251 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d13aad9-d3a7-4f6a-922c-6805f43906dc] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
+16:40:27.251 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d13aad9-d3a7-4f6a-922c-6805f43906dc] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
+16:40:27.251 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d13aad9-d3a7-4f6a-922c-6805f43906dc] Try to connect to server on start up, server: {serverIp = '12.2.0.252', server main port = 8848}
+16:40:27.251 [main] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:12.2.0.252 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+16:40:27.464 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d13aad9-d3a7-4f6a-922c-6805f43906dc] Success to connect to server [12.2.0.252:8848] on start up, connectionId = 1724229628018_12.2.0.3_62560
+16:40:27.465 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d13aad9-d3a7-4f6a-922c-6805f43906dc] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
+16:40:27.465 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d13aad9-d3a7-4f6a-922c-6805f43906dc] Notify connected event to listeners.
+16:40:27.465 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.client.naming - [onConnected,90] - Grpc connection connect
+16:40:27.465 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [8d13aad9-d3a7-4f6a-922c-6805f43906dc] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$650/0x000001f881550678
+16:40:27.467 [main] INFO  c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] muyu-cloud registering service cloud-etl with instance Instance{instanceId='null', ip='192.168.134.140', port=9701, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:9220:d890:efbb:88c6:6333:c439], preserved.register.source=SPRING_CLOUD}}
+16:40:27.521 [main] INFO  c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl 192.168.134.140:9701 register finished
+16:40:28.696 [main] INFO  c.m.e.EtlServiceApplication - [logStarted,56] - Started EtlServiceApplication in 15.281 seconds (process running for 15.676)
+16:40:28.702 [main] INFO  c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis 
+16:40:28.703 [main] INFO  c.a.n.c.c.i.CacheData - [<clinit>,99] - nacos.cache.data.init.snapshot = true 
+16:40:28.703 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl+DEFAULT_GROUP+muyu-cloud
+16:40:28.708 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl, group=DEFAULT_GROUP, cnt=1
+16:40:28.708 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl, group=DEFAULT_GROUP
+16:40:28.709 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-dev.yml+DEFAULT_GROUP+muyu-cloud
+16:40:28.709 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP, cnt=1
+16:40:28.709 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP
+16:40:28.709 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl.yml+DEFAULT_GROUP+muyu-cloud
+16:40:28.709 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl.yml, group=DEFAULT_GROUP, cnt=1
+16:40:28.709 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl.yml, group=DEFAULT_GROUP
+16:40:28.848 [RMI TCP Connection(6)-192.168.134.140] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet'
+16:43:25.306 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
+16:43:25.380 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,87] - >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://192.168.134.140:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null]
+16:43:25.380 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy.
+16:43:25.380 [SpringApplicationShutdownHook] INFO  c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
+16:43:25.381 [xxl-job, executor JobLogFileCleanThread] INFO  c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
+16:43:25.381 [xxl-job, executor TriggerCallbackThread] INFO  c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
+16:43:25.381 [Thread-11] INFO  c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
+16:43:25.388 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now...
+16:43:25.388 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] muyu-cloud deregistering service cloud-etl with instance: Instance{instanceId='null', ip='192.168.134.140', port=9701, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}}
+16:43:25.485 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished.
+16:43:25.488 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin
+16:43:25.488 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin
+16:43:25.489 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop
+16:43:25.489 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop
+16:43:25.489 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin
+16:43:25.489 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin
+16:43:25.490 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop
+16:43:25.490 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin
+16:43:25.490 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop
+16:43:25.491 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin
+16:43:25.491 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop
+16:43:25.491 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for  uuid->8d13aad9-d3a7-4f6a-922c-6805f43906dc
+16:43:25.491 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@c54eb65[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 59]
+16:43:25.491 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown
+16:43:25.491 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@a59e201[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0]
+16:43:25.491 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [closeConnection,584] - Close current connection 1724229628018_12.2.0.3_62560
+16:43:25.497 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@25880388[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 44]
+16:43:25.497 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client  for uuid ->8d13aad9-d3a7-4f6a-922c-6805f43906dc
+16:43:25.497 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped
+16:43:25.498 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed
+16:43:25.498 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop
+16:43:25.500 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+16:43:25.500 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+16:43:33.555 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+16:43:34.915 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+16:43:35.191 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+16:43:35.192 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+16:43:35.240 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+16:43:35.500 [main] INFO  c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
+16:43:35.982 [main] INFO  c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
+16:43:39.641 [main] INFO  c.m.c.r.RabbitConfig - [init,26] - rabbit启动成功
+16:43:39.881 [main] INFO  c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
+16:43:41.825 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-no-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@1727d525[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
+16:43:41.825 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-one-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@1f7b7ac4[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
+16:43:41.979 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,82] - >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999
+16:43:43.012 [main] INFO  c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
+16:43:43.013 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
+16:43:43.014 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
+16:43:43.023 [main] INFO  c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
+16:43:43.027 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
+16:43:43.028 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
+16:43:43.175 [main] INFO  c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 9a4800c7-85f8-45ee-8184-9a560a61415c
+16:43:43.176 [main] INFO  c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->9a4800c7-85f8-45ee-8184-9a560a61415c
+16:43:43.176 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [9a4800c7-85f8-45ee-8184-9a560a61415c] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
+16:43:43.176 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [9a4800c7-85f8-45ee-8184-9a560a61415c] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
+16:43:43.177 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [9a4800c7-85f8-45ee-8184-9a560a61415c] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
+16:43:43.178 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [9a4800c7-85f8-45ee-8184-9a560a61415c] Try to connect to server on start up, server: {serverIp = '12.2.0.252', server main port = 8848}
+16:43:43.179 [main] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:12.2.0.252 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+16:43:43.419 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [9a4800c7-85f8-45ee-8184-9a560a61415c] Success to connect to server [12.2.0.252:8848] on start up, connectionId = 1724229823956_12.2.0.3_62983
+16:43:43.419 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [9a4800c7-85f8-45ee-8184-9a560a61415c] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
+16:43:43.419 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [9a4800c7-85f8-45ee-8184-9a560a61415c] Notify connected event to listeners.
+16:43:43.420 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [9a4800c7-85f8-45ee-8184-9a560a61415c] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$650/0x000001448153d380
+16:43:43.420 [com.alibaba.nacos.client.remote.worker.0] INFO  c.a.n.client.naming - [onConnected,90] - Grpc connection connect
+16:43:43.422 [main] INFO  c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] muyu-cloud registering service cloud-etl with instance Instance{instanceId='null', ip='192.168.134.140', port=9701, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:9220:d890:efbb:88c6:6333:c439], preserved.register.source=SPRING_CLOUD}}
+16:43:43.534 [main] INFO  c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl 192.168.134.140:9701 register finished
+16:43:44.674 [main] INFO  c.m.e.EtlServiceApplication - [logStarted,56] - Started EtlServiceApplication in 15.558 seconds (process running for 16.035)
+16:43:44.683 [main] INFO  c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis 
+16:43:44.688 [main] INFO  c.a.n.c.c.i.CacheData - [<clinit>,99] - nacos.cache.data.init.snapshot = true 
+16:43:44.688 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl+DEFAULT_GROUP+muyu-cloud
+16:43:44.694 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl, group=DEFAULT_GROUP, cnt=1
+16:43:44.694 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl, group=DEFAULT_GROUP
+16:43:44.694 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-dev.yml+DEFAULT_GROUP+muyu-cloud
+16:43:44.694 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP, cnt=1
+16:43:44.694 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP
+16:43:44.694 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl.yml+DEFAULT_GROUP+muyu-cloud
+16:43:44.694 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl.yml, group=DEFAULT_GROUP, cnt=1
+16:43:44.694 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl.yml, group=DEFAULT_GROUP
+16:43:44.965 [RMI TCP Connection(3)-192.168.134.140] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet'
+16:46:29.213 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
+16:46:29.293 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,87] - >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://192.168.134.140:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null]
+16:46:29.294 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy.
+16:46:29.294 [SpringApplicationShutdownHook] INFO  c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
+16:46:29.295 [xxl-job, executor JobLogFileCleanThread] INFO  c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
+16:46:29.295 [xxl-job, executor TriggerCallbackThread] INFO  c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
+16:46:29.296 [Thread-11] INFO  c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
+16:46:29.317 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now...
+16:46:29.318 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] muyu-cloud deregistering service cloud-etl with instance: Instance{instanceId='null', ip='192.168.134.140', port=9701, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}}
+16:46:29.401 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished.
+16:46:29.402 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin
+16:46:29.403 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin
+16:46:29.403 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop
+16:46:29.403 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop
+16:46:29.404 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin
+16:46:29.404 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin
+16:46:29.405 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop
+16:46:29.405 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin
+16:46:29.405 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop
+16:46:29.405 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin
+16:46:29.405 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop
+16:46:29.405 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for  uuid->9a4800c7-85f8-45ee-8184-9a560a61415c
+16:46:29.406 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@18c1abab[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 55]
+16:46:29.406 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown
+16:46:29.406 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@64c5b662[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0]
+16:46:29.406 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [closeConnection,584] - Close current connection 1724229823956_12.2.0.3_62983
+16:46:29.412 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@65a562f6[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 41]
+16:46:29.412 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client  for uuid ->9a4800c7-85f8-45ee-8184-9a560a61415c
+16:46:29.413 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped
+16:46:29.413 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed
+16:46:29.413 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop
+16:46:29.416 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+16:46:29.416 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+16:46:37.975 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+16:46:39.318 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+16:46:39.573 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+16:46:39.573 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+16:46:39.628 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+16:46:39.881 [main] INFO  c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
+16:46:40.353 [main] INFO  c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
+16:46:44.071 [main] INFO  c.m.c.r.RabbitConfig - [init,26] - rabbit启动成功
+16:46:44.307 [main] INFO  c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
+16:46:46.221 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-no-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@1f7b7ac4[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
+16:46:46.221 [main] INFO  c.x.j.c.e.XxlJobExecutor - [registJobHandler,183] - >>>>>>>>>>> xxl-job register jobhandler success, name:xxl-job-demo-one-param, jobHandler:com.xxl.job.core.handler.impl.MethodJobHandler@19dffe76[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
+16:46:46.384 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,82] - >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999
+16:46:47.422 [main] INFO  c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
+16:46:47.423 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
+16:46:47.423 [main] INFO  c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
+16:46:47.426 [main] INFO  c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
+16:46:47.430 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
+16:46:47.430 [main] INFO  c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
+16:46:47.597 [main] INFO  c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 275531fa-d643-4bd6-a91b-123e027ab7c7
+16:46:47.600 [main] INFO  c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->275531fa-d643-4bd6-a91b-123e027ab7c7
+16:46:47.600 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [275531fa-d643-4bd6-a91b-123e027ab7c7] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
+16:46:47.601 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [275531fa-d643-4bd6-a91b-123e027ab7c7] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
+16:46:47.601 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [275531fa-d643-4bd6-a91b-123e027ab7c7] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
+16:46:47.602 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [275531fa-d643-4bd6-a91b-123e027ab7c7] Try to connect to server on start up, server: {serverIp = '12.2.0.252', server main port = 8848}
+16:46:47.602 [main] INFO  c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:12.2.0.252 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
+16:46:47.850 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [275531fa-d643-4bd6-a91b-123e027ab7c7] Success to connect to server [12.2.0.252:8848] on start up, connectionId = 1724230008392_12.2.0.3_63517
+16:46:47.851 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [275531fa-d643-4bd6-a91b-123e027ab7c7] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
+16:46:47.851 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [275531fa-d643-4bd6-a91b-123e027ab7c7] Notify connected event to listeners.
+16:46:47.851 [main] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [275531fa-d643-4bd6-a91b-123e027ab7c7] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$650/0x000002bf0153de20
+16:46:47.852 [com.alibaba.nacos.client.remote.worker.1] INFO  c.a.n.client.naming - [onConnected,90] - Grpc connection connect
+16:46:47.855 [main] INFO  c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] muyu-cloud registering service cloud-etl with instance Instance{instanceId='null', ip='192.168.134.140', port=9701, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:9220:d890:efbb:88c6:6333:c439], preserved.register.source=SPRING_CLOUD}}
+16:46:47.917 [main] INFO  c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl 192.168.134.140:9701 register finished
+16:46:49.052 [main] INFO  c.m.e.EtlServiceApplication - [logStarted,56] - Started EtlServiceApplication in 15.421 seconds (process running for 15.901)
+16:46:49.059 [main] INFO  c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis 
+16:46:49.059 [main] INFO  c.a.n.c.c.i.CacheData - [<clinit>,99] - nacos.cache.data.init.snapshot = true 
+16:46:49.060 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl+DEFAULT_GROUP+muyu-cloud
+16:46:49.065 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl, group=DEFAULT_GROUP, cnt=1
+16:46:49.065 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl, group=DEFAULT_GROUP
+16:46:49.065 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl-dev.yml+DEFAULT_GROUP+muyu-cloud
+16:46:49.065 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP, cnt=1
+16:46:49.065 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP
+16:46:49.065 [main] INFO  c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-muyu-cloud-12.2.0.252_8848] [subscribe] cloud-etl.yml+DEFAULT_GROUP+muyu-cloud
+16:46:49.065 [main] INFO  c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-muyu-cloud-12.2.0.252_8848] [add-listener] ok, tenant=muyu-cloud, dataId=cloud-etl.yml, group=DEFAULT_GROUP, cnt=1
+16:46:49.065 [main] INFO  c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl.yml, group=DEFAULT_GROUP
+16:46:49.508 [RMI TCP Connection(2)-192.168.134.140] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet'
+16:50:06.547 [nacos-grpc-client-executor-12.2.0.252-56] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [65e995c7-74d9-4640-95e6-67ead9a2e675_config-0] Receive server push request, request = ConfigChangeNotifyRequest, requestId = 59
+16:50:06.548 [nacos-grpc-client-executor-12.2.0.252-56] INFO  c.a.n.c.c.i.ClientWorker - [handleConfigChangeNotifyRequest,666] - [65e995c7-74d9-4640-95e6-67ead9a2e675_config-0] [server-push] config changed. dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud
+16:50:06.548 [nacos-grpc-client-executor-12.2.0.252-56] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [65e995c7-74d9-4640-95e6-67ead9a2e675_config-0] Ack server push request, request = ConfigChangeNotifyRequest, requestId = 59
+16:50:06.668 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.ClientWorker - [refreshContentAndCheck,939] - [fixed-muyu-cloud-12.2.0.252_8848] [data-received] dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP, tenant=muyu-cloud, md5=e8239cb55cb6d1a7a7813e708fea93d3, content=# spring配置
+spring:
+  data:
+    redis:
+      host: ${redis.host}
+      port: ${redis.port}
+      pass..., type=yaml
+16:50:06.669 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.CacheData - [safeNotifyListener,480] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-listener] task execute in nacos thread, dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=e8239cb55cb6d1a7a7813e708fea93d3, listener=com.alibaba.cloud.nacos.refresh.NacosContextRefresher$1@14326ffb 
+16:50:06.669 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.CacheData - [run,420] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-context] dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=e8239cb55cb6d1a7a7813e708fea93d3
+16:50:08.838 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.CacheData - [run,451] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-ok] dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=e8239cb55cb6d1a7a7813e708fea93d3, listener=com.alibaba.cloud.nacos.refresh.NacosContextRefresher$1@14326ffb ,job run cost=2169 millis.
+16:53:38.238 [nacos-grpc-client-executor-12.2.0.252-101] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [65e995c7-74d9-4640-95e6-67ead9a2e675_config-0] Receive server push request, request = ConfigChangeNotifyRequest, requestId = 61
+16:53:38.239 [nacos-grpc-client-executor-12.2.0.252-101] INFO  c.a.n.c.c.i.ClientWorker - [handleConfigChangeNotifyRequest,666] - [65e995c7-74d9-4640-95e6-67ead9a2e675_config-0] [server-push] config changed. dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud
+16:53:38.240 [nacos-grpc-client-executor-12.2.0.252-101] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [65e995c7-74d9-4640-95e6-67ead9a2e675_config-0] Ack server push request, request = ConfigChangeNotifyRequest, requestId = 61
+16:53:38.383 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.ClientWorker - [refreshContentAndCheck,939] - [fixed-muyu-cloud-12.2.0.252_8848] [data-received] dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP, tenant=muyu-cloud, md5=2109c71c0509fde4d44d6e1f97f12bf4, content=# spring配置
+spring:
+  data:
+    redis:
+      host: ${redis.host}
+      port: ${redis.port}
+      pass..., type=yaml
+16:53:38.383 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.CacheData - [safeNotifyListener,480] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-listener] task execute in nacos thread, dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=2109c71c0509fde4d44d6e1f97f12bf4, listener=com.alibaba.cloud.nacos.refresh.NacosContextRefresher$1@14326ffb 
+16:53:38.383 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.CacheData - [run,420] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-context] dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=2109c71c0509fde4d44d6e1f97f12bf4
+16:53:40.755 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.CacheData - [run,451] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-ok] dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=2109c71c0509fde4d44d6e1f97f12bf4, listener=com.alibaba.cloud.nacos.refresh.NacosContextRefresher$1@14326ffb ,job run cost=2372 millis.
+16:54:22.655 [nacos-grpc-client-executor-12.2.0.252-114] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [65e995c7-74d9-4640-95e6-67ead9a2e675_config-0] Receive server push request, request = ConfigChangeNotifyRequest, requestId = 62
+16:54:22.656 [nacos-grpc-client-executor-12.2.0.252-114] INFO  c.a.n.c.c.i.ClientWorker - [handleConfigChangeNotifyRequest,666] - [65e995c7-74d9-4640-95e6-67ead9a2e675_config-0] [server-push] config changed. dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud
+16:54:22.657 [nacos-grpc-client-executor-12.2.0.252-114] INFO  c.a.n.c.r.client - [printIfInfoEnabled,63] - [65e995c7-74d9-4640-95e6-67ead9a2e675_config-0] Ack server push request, request = ConfigChangeNotifyRequest, requestId = 62
+16:54:23.175 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.ClientWorker - [refreshContentAndCheck,939] - [fixed-muyu-cloud-12.2.0.252_8848] [data-received] dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP, tenant=muyu-cloud, md5=2fe530958f838b6de8ebdf39662a0cd1, content=# spring配置
+spring:
+  data:
+    redis:
+      host: ${redis.host}
+      port: ${redis.port}
+      pass..., type=yaml
+16:54:23.175 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.CacheData - [safeNotifyListener,480] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-listener] task execute in nacos thread, dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=2fe530958f838b6de8ebdf39662a0cd1, listener=com.alibaba.cloud.nacos.refresh.NacosContextRefresher$1@14326ffb 
+16:54:23.175 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.CacheData - [run,420] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-context] dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=2fe530958f838b6de8ebdf39662a0cd1
+16:54:25.527 [nacos.client.config.listener.task-0] INFO  c.a.n.c.c.i.CacheData - [run,451] - [fixed-muyu-cloud-12.2.0.252_8848] [notify-ok] dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP,tenant=muyu-cloud, md5=2fe530958f838b6de8ebdf39662a0cd1, listener=com.alibaba.cloud.nacos.refresh.NacosContextRefresher$1@14326ffb ,job run cost=2352 millis.
+16:55:28.671 [Thread-12] INFO  c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
+16:55:28.802 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,87] - >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://192.168.134.140:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null]
+16:55:28.802 [xxl-job, executor ExecutorRegistryThread] INFO  c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy.
+16:55:28.803 [SpringApplicationShutdownHook] INFO  c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
+16:55:28.803 [xxl-job, executor JobLogFileCleanThread] INFO  c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
+16:55:28.803 [xxl-job, executor TriggerCallbackThread] INFO  c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
+16:55:28.803 [Thread-11] INFO  c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
+16:55:28.812 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now...
+16:55:28.812 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] muyu-cloud deregistering service cloud-etl with instance: Instance{instanceId='null', ip='192.168.134.140', port=9701, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}}
+16:55:28.920 [SpringApplicationShutdownHook] INFO  c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished.
+16:55:28.921 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin
+16:55:28.921 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin
+16:55:28.922 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop
+16:55:28.922 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop
+16:55:28.922 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin
+16:55:28.922 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin
+16:55:28.922 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop
+16:55:28.922 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin
+16:55:28.922 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop
+16:55:28.922 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin
+16:55:28.922 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop
+16:55:28.922 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for  uuid->275531fa-d643-4bd6-a91b-123e027ab7c7
+16:55:28.922 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@2925b5c3[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 173]
+16:55:28.923 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown
+16:55:28.923 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@1df0bbbb[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0]
+16:55:28.923 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.client - [closeConnection,584] - Close current connection 1724230008392_12.2.0.3_63517
+16:55:28.927 [SpringApplicationShutdownHook] INFO  c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@3cea3cc4[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 105]
+16:55:28.927 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client  for uuid ->275531fa-d643-4bd6-a91b-123e027ab7c7
+16:55:28.927 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped
+16:55:28.927 [SpringApplicationShutdownHook] INFO  c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed
+16:55:28.928 [SpringApplicationShutdownHook] INFO  c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop
+16:55:28.930 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
+16:55:28.930 [SpringApplicationShutdownHook] INFO  c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
+16:55:35.928 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+16:55:37.318 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+16:55:37.576 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+16:55:37.576 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+16:55:37.637 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+16:55:38.090 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+16:55:38.094 [Druid-ConnectionPool-Create-912034375] INFO  c.a.d.p.DruidAbstractDataSource - [setFailContinuous,1900] - {dataSource-1} failContinuous is true
+16:55:38.096 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+16:56:01.622 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+16:56:02.994 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+16:56:03.260 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+16:56:03.260 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+16:56:03.321 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+16:56:04.444 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+16:56:04.446 [Druid-ConnectionPool-Create-206623154] INFO  c.a.d.p.DruidAbstractDataSource - [setFailContinuous,1900] - {dataSource-1} failContinuous is true
+16:56:04.446 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+16:57:04.550 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+16:57:06.148 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+16:57:06.463 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+16:57:06.463 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+16:57:06.520 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+16:57:06.979 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+16:57:06.981 [Druid-ConnectionPool-Create-659229738] INFO  c.a.d.p.DruidAbstractDataSource - [setFailContinuous,1900] - {dataSource-1} failContinuous is true
+16:57:06.981 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+17:05:50.902 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+17:05:52.345 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+17:05:52.653 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+17:05:52.654 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+17:05:52.705 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+17:05:53.226 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+17:05:53.228 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+17:05:53.228 [Druid-ConnectionPool-Create-659229738] INFO  c.a.d.p.DruidAbstractDataSource - [setFailContinuous,1900] - {dataSource-1} failContinuous is true
+17:13:31.520 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+17:13:32.854 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+17:13:33.116 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+17:13:33.117 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+17:13:33.186 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+17:13:36.353 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+17:13:36.354 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+17:15:44.666 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+17:15:46.076 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+17:15:46.346 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+17:15:46.346 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+17:15:46.425 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+17:16:07.825 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+17:16:07.832 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+17:18:44.312 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+17:18:45.679 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+17:18:45.939 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+17:18:45.939 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+17:18:45.993 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+17:18:50.244 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+17:18:50.247 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+17:24:58.180 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+17:24:59.668 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+17:24:59.935 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+17:24:59.935 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+17:25:00.011 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+17:25:02.885 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+17:25:02.888 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+19:09:11.688 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+19:09:13.020 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+19:09:13.282 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+19:09:13.282 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+19:09:13.332 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+19:09:13.729 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+19:09:13.731 [Druid-ConnectionPool-Create-1441963321] INFO  c.a.d.p.DruidAbstractDataSource - [setFailContinuous,1900] - {dataSource-1} failContinuous is true
+19:09:13.731 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+19:09:57.666 [main] INFO  c.m.e.EtlServiceApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
+19:09:58.961 [main] INFO  c.d.f.s.ClassPathClientScanner - [processBeanDefinitions,153] - [Forest] Created Forest Client Bean with name 'nacosServiceRemote' and Proxy of 'com.muyu.common.nacos.remote.NacosServiceRemote' client interface
+19:09:59.202 [main] INFO  o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
+19:09:59.202 [main] INFO  o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
+19:09:59.255 [main] INFO  o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
+19:09:59.657 [main] INFO  c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
+19:09:59.660 [main] INFO  o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
+19:09:59.662 [Druid-ConnectionPool-Create-1441963321] INFO  c.a.d.p.DruidAbstractDataSource - [setFailContinuous,1900] - {dataSource-1} failContinuous is true