TreeData
/
cloud-etl-source
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

初始化

master
lwj 2024-08-22 15:02:48 +08:00
commit b08c62a780
31 changed files with 39403 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
.gitignore vendored 100644
View File

@ -0,0 +1,35 @@
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store

18
Dockerfile 100644
View File

@ -0,0 +1,18 @@
# 指定构建镜像的起始镜像
FROM anolis-registry.cn-zhangjiakou.cr.aliyuncs.com/openanolis/dragonwell:17.0.4.0.4.8-standard-ga-8.6
# 执行一些必须的条件
# 定义时区参数
ENV TZ=Asia/Shanghai
# 执行一些必备的条件
RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo "$TZ" > /etc/timezone
# 挂载工作目录
VOLUME ["/home/logs"]
# 拷贝执行 jar 包文件
COPY ./cloud-etl-server/target/cloud-source.jar /home/app.jar
# 构建启动命令
ENTRYPOINT ["java", "-Dfile.encoding=utf-8", "-jar", "/home/app.jar"]

20
cloud-etl-client/pom.xml 100644
View File

@ -0,0 +1,20 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-source</artifactId>
<version>1.0.0</version>
</parent>
<artifactId>cloud-etl-client</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
</project>

7
cloud-etl-client/src/main/java/com/muyu/Main.java 100644
View File

@ -0,0 +1,7 @@
package com.muyu;
public class Main {
public static void main(String[] args) {
System.out.println("Hello world!");
}
}

27
cloud-etl-common/pom.xml 100644
View File

@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-source</artifactId>
<version>1.0.0</version>
</parent>
<artifactId>cloud-etl-common</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
</dependencies>
</project>

75
cloud-etl-common/src/main/java/com/muyu/domain/Source.java 100644
View File

@ -0,0 +1,75 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.annotation.Excel;
import com.muyu.common.core.web.domain.BaseEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@EqualsAndHashCode(callSuper = true)
@TableName(value ="source",autoResultMap = true) //数据库表相关
public class Source extends BaseEntity {
/** 主键 */
@TableId(value = "id", type = IdType.AUTO)
private Long id;
/** 接入源名称 */
@Excel(name = "接入源名称")
private String dataResourceName;
/** 数据来源系统名称 */
@Excel(name = "数据来源系统名称")
private String dataSourcesSystemName;
/** 主机ip地址 */
@Excel(name = "主机ip地址")
private String host;
/** 端口 */
@Excel(name = "端口")
private String port;
/** 数据接入类型 */
@Excel(name = "数据接入类型")
private String databaseType;
/** 数据库名称 */
@Excel(name = "数据库名称")
private String databaseName;
/** 初始化连接数量 */
@Excel(name = "初始化连接数量")
private Long initLinkNum;
/** 最大连接数量 */
@Excel(name = "最大连接数量")
private Long maxLinkNum;
/** 最大等待时间 */
@Excel(name = "最大等待时间")
private Long maxWaitTime;
/** 最大等待次数 */
@Excel(name = "最大等待次数")
private Long maxWaitTimes;
@Excel(name ="连接参数")
private String connectionParams;
@Excel(name ="用户名")
private String username;
@Excel(name ="密码")
private String password;
}

33
cloud-etl-common/src/main/java/com/muyu/domain/SourceType.java 100644
View File

@ -0,0 +1,33 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.web.domain.BaseEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@EqualsAndHashCode(callSuper = true)
@TableName(value ="sourcetype",autoResultMap = true) //数据库表相关
public class SourceType extends BaseEntity {
private static final long serialVersionUID = 1L;
//数据源类型ID
private Integer id;
//数据源类型名称
private String name;
//
@TableField(value = "driver_class")
private String driverClass;
//
private String prefix;
private String suffix;
}

233
cloud-etl-common/src/main/java/com/muyu/domain/req/SourceReq.java 100644
View File

@ -0,0 +1,233 @@
package com.muyu.domain.req;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.annotation.Excel;
import com.muyu.common.core.web.domain.BaseEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.util.Date;
import java.util.Map;
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@EqualsAndHashCode(callSuper = true)
@TableName(value ="source",autoResultMap = true) //数据库表相关
public class SourceReq extends BaseEntity {
/** 主键 */
@TableId(value = "id", type = IdType.AUTO)
private Long id;
/** 接入源名称 */
@Excel(name = "接入源名称")
private String dataResourceName;
/** 数据来源系统名称 */
@Excel(name = "数据来源系统名称")
private String dataSourcesSystemName;
/** 主机ip地址 */
@Excel(name = "主机ip地址")
private String host;
/** 端口 */
@Excel(name = "端口")
private String port;
/** 数据接入类型 */
@Excel(name = "数据接入类型")
private String databaseType;
/** 数据库名称 */
@Excel(name = "数据库名称")
private String databaseName;
/** 初始化连接数量 */
@Excel(name = "初始化连接数量")
private Long initLinkNum;
/** 最大连接数量 */
@Excel(name = "最大连接数量")
private Long maxLinkNum;
/** 最大等待时间 */
@Excel(name = "最大等待时间")
private Long maxWaitTime;
/** 最大等待次数 */
@Excel(name = "最大等待次数")
private Long maxWaitTimes;
@Excel(name ="连接参数")
private String connectionParams;
@Excel(name ="用户名")
private String username;
@Excel(name ="密码")
private String password;
@Override
public String toString() {
return "SourceReq{" +
"id=" + id +
", dataResourceName='" + dataResourceName + '\'' +
", dataSourcesSystemName='" + dataSourcesSystemName + '\'' +
", host='" + host + '\'' +
", port='" + port + '\'' +
", databaseType='" + databaseType + '\'' +
", databaseName='" + databaseName + '\'' +
", initLinkNum=" + initLinkNum +
", maxLinkNum=" + maxLinkNum +
", maxWaitTime=" + maxWaitTime +
", maxWaitTimes=" + maxWaitTimes +
'}';
}
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getDataResourceName() {
return dataResourceName;
}
public void setDataResourceName(String dataResourceName) {
this.dataResourceName = dataResourceName;
}
public String getDataSourcesSystemName() {
return dataSourcesSystemName;
}
public void setDataSourcesSystemName(String dataSourcesSystemName) {
this.dataSourcesSystemName = dataSourcesSystemName;
}
public String getHost() {
return host;
}
public void setHost(String host) {
this.host = host;
}
public String getPort() {
return port;
}
public void setPort(String port) {
this.port = port;
}
public String getDatabaseType() {
return databaseType;
}
public void setDatabaseType(String databaseType) {
this.databaseType = databaseType;
}
public String getDatabaseName() {
return databaseName;
}
public void setDatabaseName(String databaseName) {
this.databaseName = databaseName;
}
public Long getInitLinkNum() {
return initLinkNum;
}
public void setInitLinkNum(Long initLinkNum) {
this.initLinkNum = initLinkNum;
}
public Long getMaxLinkNum() {
return maxLinkNum;
}
public void setMaxLinkNum(Long maxLinkNum) {
this.maxLinkNum = maxLinkNum;
}
public Long getMaxWaitTime() {
return maxWaitTime;
}
public void setMaxWaitTime(Long maxWaitTime) {
this.maxWaitTime = maxWaitTime;
}
public Long getMaxWaitTimes() {
return maxWaitTimes;
}
public void setMaxWaitTimes(Long maxWaitTimes) {
this.maxWaitTimes = maxWaitTimes;
}
public SourceReq(BaseEntityBuilder<?, ?> b, Long id, String dataResourceName, String dataSourcesSystemName, String host, String port, String databaseType, String databaseName, Long initLinkNum, Long maxLinkNum, Long maxWaitTime, Long maxWaitTimes, String connectionParams) {
super(b);
this.id = id;
this.dataResourceName = dataResourceName;
this.dataSourcesSystemName = dataSourcesSystemName;
this.host = host;
this.port = port;
this.databaseType = databaseType;
this.databaseName = databaseName;
this.initLinkNum = initLinkNum;
this.maxLinkNum = maxLinkNum;
this.maxWaitTime = maxWaitTime;
this.maxWaitTimes = maxWaitTimes;
}
public SourceReq(Long id, String dataResourceName, String dataSourcesSystemName, String host, String port, String databaseType, String databaseName, Long initLinkNum, Long maxLinkNum, Long maxWaitTime, Long maxWaitTimes, String connectionParams) {
this.id = id;
this.dataResourceName = dataResourceName;
this.dataSourcesSystemName = dataSourcesSystemName;
this.host = host;
this.port = port;
this.databaseType = databaseType;
this.databaseName = databaseName;
this.initLinkNum = initLinkNum;
this.maxLinkNum = maxLinkNum;
this.maxWaitTime = maxWaitTime;
this.maxWaitTimes = maxWaitTimes;
}
public SourceReq(String searchValue, String createBy, Date createTime, String updateBy, Date updateTime, String remark, Map<String, Object> params, Long id, String dataResourceName, String dataSourcesSystemName, String host, String port, String databaseType, String databaseName, Long initLinkNum, Long maxLinkNum, Long maxWaitTime, Long maxWaitTimes, String connectionParams) {
super(searchValue, createBy, createTime, updateBy, updateTime, remark, params);
this.id = id;
this.dataResourceName = dataResourceName;
this.dataSourcesSystemName = dataSourcesSystemName;
this.host = host;
this.port = port;
this.databaseType = databaseType;
this.databaseName = databaseName;
this.initLinkNum = initLinkNum;
this.maxLinkNum = maxLinkNum;
this.maxWaitTime = maxWaitTime;
this.maxWaitTimes = maxWaitTimes;
}
}

28
cloud-etl-remote/pom.xml 100644
View File

@ -0,0 +1,28 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-source</artifactId>
<version>1.0.0</version>
</parent>
<artifactId>cloud-etl-remote</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-common</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies>
</project>

7
cloud-etl-remote/src/main/java/com/muyu/Main.java 100644
View File

@ -0,0 +1,7 @@
package com.muyu;
public class Main {
public static void main(String[] args) {
System.out.println("Hello world!");
}
}

146
cloud-etl-server/pom.xml 100644
View File

@ -0,0 +1,146 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-source</artifactId>
<version>1.0.0</version>
</parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-server</artifactId>
<version>1.0.0</version>
<dependencies>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-core</artifactId>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-common</artifactId>
<version>1.0.0</version>
</dependency>
<!-- SpringCloud Alibaba Nacos -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- SpringCloud Alibaba Nacos Config -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<!-- SpringCloud Alibaba Sentinel -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<!-- SpringBoot Actuator -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!-- Mysql Connector -->
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
</dependency>
<!-- MuYu Common DataSource -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-datasource</artifactId>
</dependency>
<!-- MuYu Common DataScope -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-datascope</artifactId>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-log</artifactId>
<version>3.6.3</version>
</dependency>
<!-- 接口模块 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-api-doc</artifactId>
</dependency>
<!-- XllJob定时任务 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-xxl</artifactId>
<version>3.6.3</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>com.muyu</groupId>-->
<!-- <artifactId>cloud-common-rabbit</artifactId>-->
<!-- <version>1.0.0</version>-->
<!-- </dependency>-->
<!-- <dependency>-->
<!-- <groupId>com.baomidou</groupId>-->
<!-- <artifactId>mybatis-plus-boot-starter</artifactId>-->
<!-- <version>3.5.3.1</version>-->
<!-- </dependency>-->
<!-- <dependency>-->
<!-- <groupId>com.baomidou</groupId>-->
<!-- <artifactId>mybatis-plus-core</artifactId>-->
<!-- <version>3.5.3</version> &lt;!&ndash; 请根据实际需要选择版本 &ndash;&gt;-->
<!-- </dependency>-->
</dependencies>
<build>
<finalName>cloud-source</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>3.2.6</version>
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
<!-- 加入maven deploy插件，当在deploy时，忽略些model-->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-deploy-plugin</artifactId>
<configuration>
<skip>true</skip>
</configuration>
</plugin>
</plugins>
</build>
</project>

20
cloud-etl-server/src/main/java/com/muyu/cloud/etl/MuYuEtlApplication.java 100644
View File

@ -0,0 +1,20 @@
package com.muyu.cloud.etl;
import com.muyu.common.security.annotation.EnableCustomConfig;
import com.muyu.common.security.annotation.EnableMyFeignClients;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@EnableCustomConfig
@EnableMyFeignClients
@SpringBootApplication
@MapperScan("com.muyu.cloud.etl.mapper")
public class MuYuEtlApplication {
public static void main (String[] args) {
SpringApplication.run(MuYuEtlApplication.class, args);
}
}

97
cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/SourceController.java 100644
View File

@ -0,0 +1,97 @@
package com.muyu.cloud.etl.controller;
import com.muyu.cloud.etl.service.SourceService;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.poi.ExcelUtil;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.domain.Source;
import com.muyu.domain.req.SourceReq;
import jakarta.servlet.ServletException;
import jakarta.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@RestController
@RequestMapping("/source")
public class SourceController extends BaseController {
@Autowired
private SourceService sourceService;
//列表
@PostMapping("/list")
public Result<TableDataInfo<Source>> list(@RequestBody SourceReq sourceReq) {
startPage();
List<Source> list = sourceService.selectSourceList(sourceReq);
return getDataTable(list);
}
/*
* 导出
*/
@PostMapping("/export")
public void export(HttpServletResponse response, SourceReq sourceReq) {
List<Source> list= sourceService.selectSourceList(sourceReq);
ExcelUtil<Source> util = new ExcelUtil<>(Source.class);
util.exportExcel(response,list,"基础信息");
}
/**
* 获取基础信息详细信息
*/
@GetMapping(value = "/{id}")
public Result getInfo(@PathVariable("id") Long id) {
Source source= sourceService.getInfo(id);
return success(source);
}
/**
* 新增基础信息
*/
@PostMapping("/insert")
public Result add(@RequestBody Source sourceReq) {
return toAjax(sourceService.insertBasicConfigInfo(sourceReq));
}
//批量删除
@DeleteMapping("{ids}")
public Integer delete(@PathVariable("ids") String ids) {
return sourceService.deleteByIds(ids);
}
/**
* 修改
*/
@PostMapping("/update")
public Result update(@RequestBody Source sourceReq) {
return toAjax(sourceService.updataSource(sourceReq));
}
/**
* 测试连接
*/
@PostMapping("/connectionTest")
public Result connectionTest(@RequestBody Source source) throws ServletException {
return toAjax(sourceService.connectionTest(source));
}
}

27
cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/SourceTypeController.java 100644
View File

@ -0,0 +1,27 @@
package com.muyu.cloud.etl.controller;
import com.muyu.cloud.etl.service.SourceTypeService;
import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.domain.SourceType;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@RestController
@RequestMapping("/SourceType")
public class SourceTypeController extends BaseController {
@Autowired
private SourceTypeService sourceTypeService;
@GetMapping("/findSourceType")
public Result<List<SourceType>> findSourceType() {
List<SourceType> sourceTypeList=sourceTypeService.findSourceType();
return Result.success(sourceTypeList);
}
}

16
cloud-etl-server/src/main/java/com/muyu/cloud/etl/mapper/SourceMapper.java 100644
View File

@ -0,0 +1,16 @@
package com.muyu.cloud.etl.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.Source;
import com.muyu.domain.req.SourceReq;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
@Mapper
public interface SourceMapper extends BaseMapper<Source> {
List<Source> selectSourceList(SourceReq sourceReq);
Integer updataSource(Source sourceReq);
}

9
cloud-etl-server/src/main/java/com/muyu/cloud/etl/mapper/SourceTypeMapper.java 100644
View File

@ -0,0 +1,9 @@
package com.muyu.cloud.etl.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.SourceType;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface SourceTypeMapper extends BaseMapper<SourceType> {
}

21
cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/SourceService.java 100644
View File

@ -0,0 +1,21 @@
package com.muyu.cloud.etl.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.Source;
import com.muyu.domain.req.SourceReq;
import java.util.List;
public interface SourceService extends IService<Source> {
List<Source> selectSourceList(SourceReq sourceReq);
Source getInfo(Long id);
int insertBasicConfigInfo(Source sourceReq);
Integer deleteByIds(String ids);
int updataSource(Source sourceReq);
int connectionTest(Source source);
}

11
cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/SourceTypeService.java 100644
View File

@ -0,0 +1,11 @@
package com.muyu.cloud.etl.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.SourceType;
import java.util.List;
public interface SourceTypeService extends IService<SourceType> {
List<SourceType> findSourceType();
}

77
cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java 100644
View File

@ -0,0 +1,77 @@
package com.muyu.cloud.etl.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.cloud.etl.mapper.SourceMapper;
import com.muyu.cloud.etl.service.SourceService;
import com.muyu.domain.Source;
import com.muyu.domain.req.SourceReq;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.List;
@Service
public class SourceServiceImpl extends ServiceImpl<SourceMapper, Source> implements SourceService {
@Autowired
private SourceMapper sourceMapper;
@Override
public List<Source> selectSourceList(SourceReq sourceReq) {
return sourceMapper.selectSourceList(sourceReq);
}
@Override
public Source getInfo(Long id) {
LambdaQueryWrapper<Source> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.eq(Source::getId, id);
return this.sourceMapper.selectOne(lambdaQueryWrapper);
}
//新增
@Override
public int insertBasicConfigInfo(Source sourceReq) {
int insert = sourceMapper.insert(sourceReq);
return insert;
}
@Override
public Integer deleteByIds(String ids) {
LambdaQueryWrapper<Source> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.in(Source::getId, ids);
int delete = sourceMapper.delete(lambdaQueryWrapper);
return delete;
}
@Override
public int updataSource(Source sourceReq) {
Integer i= sourceMapper.updataSource(sourceReq);
return i;
}
@Override
public int connectionTest(Source source) {
String host = source.getHost();
String port = source.getPort();
String databaseName = source.getDatabaseName();
String databaseType = source.getDatabaseType();
String url = "jdbc:" + databaseType + "://" + host + ":" + port + "/" + databaseName + "?" + source.getConnectionParams();
String user = source.getUsername();
String password = source.getPassword();
Connection conn = null;
try {
conn = DriverManager.getConnection(url, user, password);
} catch (SQLException e) {
throw new RuntimeException(e);
}
return 1;
}
}

20
cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceTypeServiceImpl.java 100644
View File

@ -0,0 +1,20 @@
package com.muyu.cloud.etl.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.cloud.etl.mapper.SourceTypeMapper;
import com.muyu.cloud.etl.service.SourceTypeService;
import com.muyu.domain.SourceType;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class SourceTypeServiceImpl extends ServiceImpl<SourceTypeMapper, SourceType> implements SourceTypeService {
@Override
public List<SourceType> findSourceType() {
LambdaQueryWrapper<SourceType> sourceTypeLambdaQueryWrapper = new LambdaQueryWrapper<>();
return this.list(sourceTypeLambdaQueryWrapper);
}
}

2
cloud-etl-server/src/main/resources/banner.txt 100644
View File

@ -0,0 +1,2 @@
Spring Boot Version: ${spring-boot.version}
Spring Application Name: ${spring.application.name}

61
cloud-etl-server/src/main/resources/bootstrap.yml 100644
View File

@ -0,0 +1,61 @@
# Tomcat
server:
port: 10005
# nacos线上地址
nacos:
addr: 47.116.184.54:8848
user-name: nacos
password: nacos
namespace: cloud-2112
# Spring
spring:
application:
# 应用名称
name: cloud-etl-source
profiles:
# 环境配置
active: dev
cloud:
nacos:
discovery:
# 服务注册地址
server-addr: ${nacos.addr}
# nacos用户名
username: ${nacos.user-name}
# nacos密码
password: ${nacos.password}
# 命名空间
namespace: ${nacos.namespace}
config:
# 服务注册地址
server-addr: ${nacos.addr}
# nacos用户名
username: ${nacos.user-name}
# nacos密码
password: ${nacos.password}
# 命名空间
namespace: ${nacos.namespace}
# 配置文件格式
file-extension: yml
# 共享配置
shared-configs:
# 系统共享配置
- application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
# 系统环境Config共享配置
- application-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
- application-xxl-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
# rabbit 配置文件
- application-rabbit-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
mybatis-plus:
configuration:
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl # 配置 MyBatis 的日志输出实现类，这里是输出到控制台
mapper-locations: classpath:/mapper/*.xml # MyBatis Mapper 文件的位置，这里假设是 XML 形式的 Mapper
global-config:
db-config:
id-type: auto # 主键生成策略，这里设置为自动增长
logic-delete-value: 1 # 逻辑删除标记值，例如设置为 1 表示已删除
logic-not-delete-value: 0 # 逻辑未删除标记值，例如设置为 0 表示未删除
banner: false # 关闭控制台打印的 MyBatis-Plus Banner

74
cloud-etl-server/src/main/resources/logback/dev.xml 100644
View File

@ -0,0 +1,74 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<!-- 日志存放路径 -->
<property name="log.path" value="logs/cloud-etl"/>
<!-- 日志输出格式 -->
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<!-- 控制台输出 -->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
</appender>
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<encoder>
<pattern>${log.pattern}</pattern>
</encoder>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 系统模块日志级别控制 -->
<logger name="com.muyu" level="info"/>
<!-- Spring日志级别控制 -->
<logger name="org.springframework" level="warn"/>
<root level="info">
<appender-ref ref="console"/>
</root>
<!--系统操作日志-->
<root level="info">
<appender-ref ref="file_info"/>
<appender-ref ref="file_error"/>
</root>
</configuration>

81
cloud-etl-server/src/main/resources/logback/prod.xml 100644
View File

@ -0,0 +1,81 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<!-- 日志存放路径 -->
<property name="log.path" value="logs/cloud-etl"/>
<!-- 日志输出格式 -->
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<property name="log.sky.pattern" value="%d{HH:mm:ss.SSS} %yellow([%tid]) [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<!-- 控制台输出 -->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${log.sky.pattern}</pattern>
</encoder>
</appender>
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 使用gRpc将日志发送到skywalking服务端 -->
<appender name="GRPC_LOG" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<Pattern>${log.sky.pattern}</Pattern>
</layout>
</encoder>
</appender>
<!-- 系统模块日志级别控制 -->
<logger name="com.muyu" level="info"/>
<!-- Spring日志级别控制 -->
<logger name="org.springframework" level="warn"/>
<root level="info">
<appender-ref ref="GRPC_LOG"/>
<appender-ref ref="console"/>
</root>
<!--系统操作日志-->
<root level="info">
<appender-ref ref="file_info"/>
<appender-ref ref="file_error"/>
</root>
</configuration>

81
cloud-etl-server/src/main/resources/logback/test.xml 100644
View File

@ -0,0 +1,81 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod="60 seconds" debug="false">
<!-- 日志存放路径 -->
<property name="log.path" value="logs/cloud-text"/>
<!-- 日志输出格式 -->
<property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<property name="log.sky.pattern" value="%d{HH:mm:ss.SSS} %yellow([%tid]) [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/>
<!-- 控制台输出 -->
<appender name="console" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>${log.sky.pattern}</pattern>
</encoder>
</appender>
<!-- 系统日志输出 -->
<appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/info.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/info.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>INFO</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.path}/error.log</file>
<!-- 循环政策：基于时间创建日志文件 -->
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<!-- 日志文件名格式 -->
<fileNamePattern>${log.path}/error.%d{yyyy-MM-dd}.log</fileNamePattern>
<!-- 日志最大的历史 60天 -->
<maxHistory>60</maxHistory>
</rollingPolicy>
<filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 -->
<level>ERROR</level>
<!-- 匹配时的操作：接收（记录） -->
<onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作：拒绝（不记录） -->
<onMismatch>DENY</onMismatch>
</filter>
</appender>
<!-- 使用gRpc将日志发送到skywalking服务端 -->
<appender name="GRPC_LOG" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<Pattern>${log.sky.pattern}</Pattern>
</layout>
</encoder>
</appender>
<!-- 系统模块日志级别控制 -->
<logger name="com.muyu" level="info"/>
<!-- Spring日志级别控制 -->
<logger name="org.springframework" level="warn"/>
<root level="info">
<appender-ref ref="GRPC_LOG"/>
<appender-ref ref="console"/>
</root>
<!--系统操作日志-->
<root level="info">
<appender-ref ref="file_info"/>
<appender-ref ref="file_error"/>
</root>
</configuration>

67
cloud-etl-server/src/main/resources/mapper/SourceMapper.xml 100644
View File

@ -0,0 +1,67 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.muyu.cloud.etl.mapper.SourceMapper">
<resultMap type="com.muyu.domain.Source" id="SourceMapper">
<result property="id" column="id" />
<result property="dataResourceName" column="data_resource_name" />
<result property="dataSourcesSystemName" column="data_sources_system_name" />
<result property="host" column="host" />
<result property="port" column="port" />
<result property="databaseType" column="database_type" />
<result property="databaseName" column="database_name" />
<result property="initLinkNum" column="init_link_num" />
<result property="maxLinkNum" column="max_link_num" />
<result property="maxWaitTime" column="max_wait_time" />
<result property="maxWaitTimes" column="max_wait_times" />
<result property="connectionParams" column="connection_params" />
<result property="remark" column="remark" />
</resultMap>
<sql id="selectSourceList">
select id, data_resource_name,username,password, data_sources_system_name, host, port, database_type, database_name, init_link_num, max_link_num, max_wait_time, max_wait_times,connection_params, remark from source
</sql>
<update id="updataSource">
update source
<trim prefix="SET" suffixOverrides=",">
<if test="dataResourceName != null">data_resource_name = #{dataResourceName},</if>
<if test="dataSourcesSystemName != null">data_sources_system_name = #{dataSourcesSystemName},</if>
<if test="host != null">host = #{host},</if>
<if test="port != null">port = #{port},</if>
<if test="databaseType != null">database_type = #{databaseType},</if>
<if test="databaseName != null">database_name = #{databaseName},</if>
<if test="username != null">username = #{username},</if>
<if test="password != null">password = #{password},</if>
<if test="initLinkNum != null">init_link_num = #{initLinkNum},</if>
<if test="maxLinkNum != null">max_link_num = #{maxLinkNum},</if>
<if test="maxWaitTime != null">max_wait_time = #{maxWaitTime},</if>
<if test="maxWaitTimes != null">max_wait_times = #{maxWaitTimes},</if>
<if test="connectionParams != null">connection_params = #{connectionParams},</if>
<if test="remark != null">remark = #{remark},</if>
</trim>
where id = #{id}
</update>
<!-- <select id="selectSourceList" resultType="com.muyu.domain.Source">-->
<!-- -->
<!-- </select>-->
<select id="selectSourceList" parameterType="com.muyu.domain.Source" resultMap="SourceMapper">
<include refid="selectSourceList"/>
<where>
<if test="dataResourceName != null and dataResourceName != ''"> and data_resource_name like concat('%', #{dataResourceName}, '%')</if>
<if test="dataSourcesSystemName != null and dataSourcesSystemName != ''"> and data_sources_system_name like concat('%', #{dataSourcesSystemName}, '%')</if>
<if test="host != null and host != ''"> and host = #{host}</if>
<if test="port != null and port != ''"> and port = #{port}</if>
<if test="databaseType != null and databaseType != ''"> and database_type = #{databaseType}</if>
<if test="databaseName != null and databaseName != ''"> and database_name like concat('%', #{databaseName}, '%')</if>
<if test="username != null "> and username = #{username}</if>
<if test="password != null "> and password = #{password}</if>
<if test="initLinkNum != null "> and init_link_num = #{initLinkNum}</if>
<if test="maxLinkNum != null "> and max_link_num = #{maxLinkNum}</if>
<if test="maxWaitTime != null "> and max_wait_time = #{maxWaitTime}</if>
<if test="maxWaitTimes != null "> and max_wait_times = #{maxWaitTimes}</if>
</where>
</select>
</mapper>

4182
logs/cloud-etl/error.2024-08-21.log 100644
View File

File diff suppressed because it is too large Load Diff

29203
logs/cloud-etl/error.log 100644
View File

File diff suppressed because it is too large Load Diff

493
logs/cloud-etl/info.2024-08-21.log 100644
View File

@ -0,0 +1,493 @@
21:57:00.119 [main] INFO c.m.c.p.MuYuPayApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
21:57:02.897 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7f2170ab-6b0b-42ea-9b4e-df9d93e6215b_config-0] Fail to connect server, after trying 1 times, last try server is {serverIp = '106.14.148.95', server main port = 8848}, error = unknown
21:57:02.936 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
21:57:02.936 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
21:57:03.033 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
21:57:03.099 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:03.950 [main] INFO c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
21:57:05.826 [main] INFO c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
21:57:06.112 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7f2170ab-6b0b-42ea-9b4e-df9d93e6215b_config-0] Fail to connect server, after trying 2 times, last try server is {serverIp = '106.14.148.95', server main port = 8848}, error = unknown
21:57:06.427 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:06.663 [main] INFO c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
21:57:08.048 [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@46092840[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
21:57:08.049 [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@57082d16[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
21:57:08.330 [main] INFO c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
21:57:08.331 [main] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
21:57:08.331 [main] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
21:57:08.337 [main] INFO c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
21:57:08.343 [main] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
21:57:08.343 [main] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
21:57:08.377 [Thread-11] 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
21:57:09.444 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7f2170ab-6b0b-42ea-9b4e-df9d93e6215b_config-0] Fail to connect server, after trying 3 times, last try server is {serverIp = '106.14.148.95', server main port = 8848}, error = unknown
21:57:09.848 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:11.360 [main] INFO c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 8dfa2565-bc8f-4ec1-83e4-c32e88866f91
21:57:11.362 [main] INFO c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->8dfa2565-bc8f-4ec1-83e4-c32e88866f91
21:57:11.363 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8dfa2565-bc8f-4ec1-83e4-c32e88866f91] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
21:57:11.363 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8dfa2565-bc8f-4ec1-83e4-c32e88866f91] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
21:57:11.363 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8dfa2565-bc8f-4ec1-83e4-c32e88866f91] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
21:57:11.364 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8dfa2565-bc8f-4ec1-83e4-c32e88866f91] Try to connect to server on start up, server: {serverIp = '106.14.148.95', server main port = 8848}
21:57:11.364 [main] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:11.387 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://192.168.137.1:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connect timed out), for url : http://47.116.173.75:20800/api/registry, content=null]
21:57:12.854 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7f2170ab-6b0b-42ea-9b4e-df9d93e6215b_config-0] Fail to connect server, after trying 4 times, last try server is {serverIp = '106.14.148.95', server main port = 8848}, error = unknown
21:57:13.367 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:14.379 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8dfa2565-bc8f-4ec1-83e4-c32e88866f91] Try to connect to server on start up, server: {serverIp = '106.14.148.95', server main port = 8848}
21:57:14.379 [main] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:16.380 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7f2170ab-6b0b-42ea-9b4e-df9d93e6215b_config-0] Fail to connect server, after trying 5 times, last try server is {serverIp = '106.14.148.95', server main port = 8848}, error = unknown
21:57:16.985 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:17.392 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8dfa2565-bc8f-4ec1-83e4-c32e88866f91] Try to connect to server on start up, server: {serverIp = '106.14.148.95', server main port = 8848}
21:57:17.392 [main] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:19.988 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7f2170ab-6b0b-42ea-9b4e-df9d93e6215b_config-0] Fail to connect server, after trying 6 times, last try server is {serverIp = '106.14.148.95', server main port = 8848}, error = unknown
21:57:20.409 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8dfa2565-bc8f-4ec1-83e4-c32e88866f91] Try to connect to server on start up, server: {serverIp = '106.14.148.95', server main port = 8848}
21:57:20.409 [main] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:20.705 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:23.421 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8dfa2565-bc8f-4ec1-83e4-c32e88866f91] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
21:57:23.421 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8dfa2565-bc8f-4ec1-83e4-c32e88866f91] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$629/0x00000272814f3c28
21:57:23.422 [main] INFO c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] cloud-2112 registering service cloud-etl with instance Instance{instanceId='null', ip='192.168.1.124', port=10002, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=null, preserved.register.source=SPRING_CLOUD}}
21:57:23.427 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8dfa2565-bc8f-4ec1-83e4-c32e88866f91] Try to reconnect to a new server, server is not appointed, will choose a random server.
21:57:23.428 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:23.717 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7f2170ab-6b0b-42ea-9b4e-df9d93e6215b_config-0] Fail to connect server, after trying 7 times, last try server is {serverIp = '106.14.148.95', server main port = 8848}, error = unknown
21:57:23.902 [Thread-11] INFO c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
21:57:24.524 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:26.546 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:106.14.148.95 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
21:57:26.920 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,90] - >>>>>>>>>>> xxl-job registry-remove fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://192.168.137.1:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connect timed out), for url : http://47.116.173.75:20800/api/registryRemove, content=null]
21:57:26.920 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy.
21:57:26.920 [main] INFO c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
21:57:26.920 [xxl-job, executor JobLogFileCleanThread] INFO c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
21:57:26.921 [xxl-job, executor TriggerCallbackThread] INFO c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
21:57:26.921 [Thread-10] INFO c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
21:57:26.931 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
21:57:26.932 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
21:57:26.932 [main] INFO c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin
21:57:26.932 [main] INFO c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin
21:57:26.932 [main] INFO c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop
21:57:26.932 [main] INFO c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop
21:57:26.932 [main] INFO c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin
21:57:26.932 [main] INFO c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin
21:57:26.933 [main] INFO c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop
21:57:26.933 [main] INFO c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin
21:57:26.933 [main] INFO c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop
21:57:26.933 [main] INFO c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin
21:57:26.933 [main] INFO c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop
21:57:26.933 [main] INFO c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for uuid->8dfa2565-bc8f-4ec1-83e4-c32e88866f91
21:57:26.933 [main] INFO c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@6dd65b79[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 5]
21:57:26.933 [main] INFO c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown
21:57:26.933 [main] INFO c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@1b136640[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0]
21:57:26.934 [main] INFO c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@22a7ff5d[Running, pool size = 12, active threads = 0, queued tasks = 0, completed tasks = 17]
21:57:26.934 [main] INFO c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client for uuid ->8dfa2565-bc8f-4ec1-83e4-c32e88866f91
21:57:26.934 [main] INFO c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped
21:57:26.935 [main] INFO c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed
21:57:26.935 [main] INFO c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop
21:57:26.938 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
21:57:26.938 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [8dfa2565-bc8f-4ec1-83e4-c32e88866f91] Fail to connect server, after trying 1 times, last try server is {serverIp = '106.14.148.95', server main port = 8848}, error = unknown
21:58:07.327 [main] INFO c.m.c.p.MuYuPayApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
21:58:09.709 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
21:58:09.709 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
21:58:09.782 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
21:58:10.493 [main] INFO c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
21:58:12.219 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
21:58:12.222 [Druid-ConnectionPool-Create-136289025] INFO c.a.d.p.DruidAbstractDataSource - [setFailContinuous,1900] - {dataSource-1} failContinuous is true
21:58:12.223 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
11:33:52.158 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
11:33:54.779 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
11:33:54.779 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
11:33:54.858 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
11:33:55.452 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
11:33:55.453 [Druid-ConnectionPool-Create-1932244125] INFO c.a.d.p.DruidAbstractDataSource - [setFailContinuous,1900] - {dataSource-1} failContinuous is true
11:33:55.454 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
15:17:02.164 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
15:17:05.037 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
15:17:05.038 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
15:17:05.119 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
15:17:06.027 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
15:17:06.029 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
15:18:27.316 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
15:18:29.968 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
15:18:29.968 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
15:18:30.048 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
15:18:33.181 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
15:18:33.182 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
15:18:33.182 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
15:18:33.255 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
15:18:33.257 [main] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
15:18:33.263 [main] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
15:18:33.263 [main] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
15:18:33.263 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
15:18:33.264 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
16:53:52.848 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
16:53:55.631 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
16:53:55.631 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
16:53:55.716 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
16:54:05.735 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
16:54:05.736 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
16:54:05.736 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
16:54:05.804 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
16:54:05.807 [main] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
16:54:05.811 [main] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
16:54:05.812 [main] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
16:54:05.812 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
16:54:05.813 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
16:55:49.373 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
16:55:52.273 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
16:55:52.273 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
16:55:52.358 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
16:56:03.814 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
16:56:03.815 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
16:56:03.815 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
16:56:03.883 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
16:56:03.885 [main] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
16:56:03.891 [main] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
16:56:03.892 [main] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
16:56:03.892 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
16:56:03.893 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
17:01:50.788 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
17:01:53.569 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
17:01:53.570 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
17:01:53.657 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
17:02:05.835 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
17:02:05.836 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
17:02:05.836 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
17:02:05.904 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
17:02:05.907 [main] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
17:02:05.912 [main] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
17:02:05.912 [main] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
17:02:05.912 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
17:02:05.914 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
17:05:20.380 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
17:05:23.079 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
17:05:23.080 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
17:05:23.161 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
17:05:33.934 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
17:05:33.935 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
17:05:33.935 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
17:05:34.004 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
17:05:34.006 [main] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
17:05:34.012 [main] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
17:05:34.012 [main] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
17:05:34.012 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
17:05:34.013 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
17:06:26.192 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
17:06:29.039 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
17:06:29.040 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
17:06:29.126 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
17:06:37.510 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
17:06:37.511 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
17:06:37.511 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
17:06:37.580 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
17:06:37.583 [main] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
17:06:37.588 [main] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
17:06:37.588 [main] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
17:06:37.588 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
17:06:37.589 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
17:12:21.416 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
17:12:24.221 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
17:12:24.221 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
17:12:24.305 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
17:12:32.095 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
17:12:32.096 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
17:12:32.096 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
17:12:32.165 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
17:12:32.167 [main] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
17:12:32.173 [main] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
17:12:32.174 [main] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
17:12:32.174 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
17:12:32.174 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
17:17:52.953 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
17:17:55.827 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
17:17:55.828 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
17:17:55.910 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
17:18:06.484 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
17:18:06.485 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
17:18:06.485 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
17:18:06.552 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
17:18:06.556 [main] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
17:18:06.561 [main] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
17:18:06.561 [main] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
17:18:06.561 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
17:18:06.562 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
19:37:03.323 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
19:37:04.066 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
19:37:06.272 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
19:37:06.272 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
19:37:06.345 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
19:37:07.073 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 1 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
19:37:07.274 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
19:37:10.290 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 2 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
19:37:10.600 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
19:37:13.612 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 3 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
19:37:14.019 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
19:37:17.024 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 4 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
19:37:17.538 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
19:37:20.552 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 5 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
19:37:21.154 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
19:37:24.162 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 6 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
19:37:24.865 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
19:37:27.882 [com.alibaba.nacos.client.remote.worker.1] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [6e844a98-5d6e-43b4-828d-215fb4486735_config-0] Fail to connect server, after trying 7 times, last try server is {serverIp = '47.116.184.54', server main port = 8848}, error = unknown
19:37:27.958 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
19:37:27.963 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
19:59:32.809 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
19:59:35.165 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
19:59:35.166 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
19:59:35.239 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
19:59:56.790 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
19:59:56.793 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
20:00:53.771 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
20:00:55.989 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
20:00:55.989 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
20:00:56.060 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
20:00:59.314 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
20:00:59.315 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
20:00:59.315 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
20:00:59.398 [main] INFO c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
20:00:59.404 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
20:00:59.407 [main] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
20:00:59.412 [main] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
20:00:59.412 [main] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
20:00:59.412 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
20:00:59.412 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
20:03:41.058 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
20:03:43.435 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
20:03:43.435 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
20:03:43.512 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
20:03:54.179 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
20:03:54.180 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
20:03:54.181 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
20:03:54.285 [main] INFO c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
20:03:54.292 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
20:03:54.294 [main] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
20:03:54.301 [main] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
20:03:54.301 [main] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
20:03:54.301 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
20:03:54.302 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
20:05:54.859 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
20:05:56.983 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
20:05:56.984 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
20:05:57.055 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
20:05:59.710 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
20:05:59.711 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
20:05:59.711 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
20:05:59.797 [main] INFO c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
20:06:00.570 [main] INFO c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
20:06:04.726 [main] INFO c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
20:06:06.977 [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@2baf9c62[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
20:06:06.977 [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@57202722[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
20:06:07.235 [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
20:06:08.227 [main] INFO c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
20:06:08.228 [main] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
20:06:08.228 [main] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
20:06:08.233 [main] INFO c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
20:06:08.237 [main] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
20:06:08.238 [main] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
20:06:08.600 [main] INFO c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of c7efe9cc-dfbc-44af-87d5-67cf323feb9a
20:06:08.601 [main] INFO c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->c7efe9cc-dfbc-44af-87d5-67cf323feb9a
20:06:08.602 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
20:06:08.602 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
20:06:08.602 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
20:06:08.603 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Try to connect to server on start up, server: {serverIp = '47.116.184.54', server main port = 8848}
20:06:08.603 [main] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
20:06:08.766 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Success to connect to server [47.116.184.54:8848] on start up, connectionId = 1724241970687_139.224.212.27_63406
20:06:08.766 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
20:06:08.766 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$632/0x0000017b81524078
20:06:08.766 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [c7efe9cc-dfbc-44af-87d5-67cf323feb9a] Notify connected event to listeners.
20:06:08.766 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.client.naming - [onConnected,90] - Grpc connection connect
20:06:08.767 [main] INFO c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] text registering service cloud-etl with instance Instance{instanceId='null', ip='192.168.43.160', port=10005, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:8f05:857f:85b2:f98e:707c:9340], preserved.register.source=SPRING_CLOUD}}
20:06:08.814 [main] INFO c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl 192.168.43.160:10005 register finished
20:06:09.976 [main] INFO c.m.c.e.MuYuEtlApplication - [logStarted,56] - Started MuYuEtlApplication in 20.045 seconds (process running for 20.759)
20:06:09.985 [main] INFO c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis
20:06:09.986 [main] INFO c.a.n.c.c.i.CacheData - [<clinit>,99] - nacos.cache.data.init.snapshot = true
20:06:09.987 [main] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl+DEFAULT_GROUP+text
20:06:09.996 [main] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl, group=DEFAULT_GROUP, cnt=1
20:06:09.996 [main] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl, group=DEFAULT_GROUP
20:06:09.997 [main] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl-dev.yml+DEFAULT_GROUP+text
20:06:09.998 [main] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP, cnt=1
20:06:09.998 [main] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP
20:06:09.998 [main] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl.yml+DEFAULT_GROUP+text
20:06:09.998 [main] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl.yml, group=DEFAULT_GROUP, cnt=1
20:06:09.998 [main] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl.yml, group=DEFAULT_GROUP
20:06:10.500 [RMI TCP Connection(2)-172.16.0.8] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet'
20:38:54.807 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
20:38:57.222 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
20:38:57.222 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
20:38:57.293 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
20:39:00.311 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
20:39:00.312 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
20:39:00.313 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
20:39:00.409 [main] INFO c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
20:39:01.316 [main] INFO c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
20:39:07.499 [main] INFO c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
20:39:09.861 [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@3e0e2a80[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
20:39:09.861 [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@4d696bac[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
20:39:09.889 [main] INFO c.x.j.c.util.NetUtil - [isPortUsed,56] - >>>>>>>>>>> xxl-job, port[9999] is in use.
20:39:09.963 [main] INFO c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
20:39:09.964 [xxl-job, executor JobLogFileCleanThread] INFO c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
20:39:09.964 [xxl-job, executor TriggerCallbackThread] INFO c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
20:39:09.964 [Thread-11] INFO c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
20:39:09.980 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
20:39:09.983 [main] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
20:39:09.991 [main] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
20:39:09.991 [main] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
20:39:09.991 [main] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
20:39:09.992 [main] INFO o.a.c.c.StandardService - [log,173] - Stopping service [Tomcat]
20:39:10.180 [Thread-12] INFO c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
20:39:58.483 [Thread-12] INFO c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
20:39:58.527 [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://172.16.0.8:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null]
20:39:58.528 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy.
20:39:58.528 [SpringApplicationShutdownHook] INFO c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
20:39:58.529 [xxl-job, executor JobLogFileCleanThread] INFO c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
20:39:58.530 [xxl-job, executor TriggerCallbackThread] INFO c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
20:39:58.530 [Thread-11] INFO c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
20:39:58.544 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now...
20:39:58.545 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] text deregistering service cloud-etl with instance: Instance{instanceId='null', ip='192.168.43.160', port=10005, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}}
20:39:58.620 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished.
20:39:58.621 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin
20:39:58.621 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin
20:39:58.622 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop
20:39:58.622 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop
20:39:58.622 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin
20:39:58.622 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin
20:39:58.622 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop
20:39:58.622 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin
20:39:58.622 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop
20:39:58.622 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin
20:39:58.624 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop
20:39:58.624 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for uuid->c7efe9cc-dfbc-44af-87d5-67cf323feb9a
20:39:58.624 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@78a38d9[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 674]
20:39:58.624 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown
20:39:58.624 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@638eba84[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0]
20:39:58.624 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [closeConnection,584] - Close current connection 1724241970687_139.224.212.27_63406
20:39:58.632 [SpringApplicationShutdownHook] INFO c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@780e9f6e[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 402]
20:39:58.632 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client for uuid ->c7efe9cc-dfbc-44af-87d5-67cf323feb9a
20:39:58.632 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped
20:39:58.634 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed
20:39:58.634 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop
20:39:58.638 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
20:39:58.644 [SpringApplicationShutdownHook] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
20:39:58.661 [SpringApplicationShutdownHook] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
20:39:58.661 [SpringApplicationShutdownHook] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
20:39:58.661 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye
20:42:42.803 [main] INFO c.m.c.e.MuYuEtlApplication - [logStartupProfileInfo,660] - The following 1 profile is active: "dev"
20:42:45.239 [main] INFO o.a.c.c.StandardService - [log,173] - Starting service [Tomcat]
20:42:45.239 [main] INFO o.a.c.c.StandardEngine - [log,173] - Starting Servlet engine: [Apache Tomcat/10.1.24]
20:42:45.314 [main] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring embedded WebApplicationContext
20:42:48.806 [main] INFO c.a.d.p.DruidDataSource - [init,1002] - {dataSource-1,master} inited
20:42:48.808 [main] INFO c.b.d.d.DynamicRoutingDataSource - [addDataSource,158] - dynamic-datasource - add a datasource named [master] success
20:42:48.808 [main] INFO c.b.d.d.DynamicRoutingDataSource - [afterPropertiesSet,241] - dynamic-datasource initial loaded [1] datasource,primary datasource named [master]
20:42:48.897 [main] INFO c.m.c.d.MyMetaObjectHandler - [<init>,17] - 元对象字段填充控制器 ------- 加载完成
20:42:49.768 [main] INFO c.a.c.s.SentinelWebMvcConfigurer - [addInterceptors,52] - [Sentinel Starter] register SentinelWebInterceptor with urlPatterns: [/**].
20:42:55.783 [main] INFO c.m.c.x.XXLJobConfig - [xxlJobExecutor,25] - >>>>>>>>>>> xxl-job config init success.
20:42:58.171 [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@1290fc6a[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoNoParam]
20:42:58.171 [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@6ee7c941[class com.muyu.common.xxl.demo.XxlJobDemoService#xxlJobDemoOneParam]
20:42:58.473 [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
20:42:59.463 [main] INFO c.a.n.client.naming - [initNamespaceForNaming,62] - initializer namespace from ans.namespace attribute : null
20:42:59.464 [main] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$0,66] - initializer namespace from ALIBABA_ALIWARE_NAMESPACE attribute :null
20:42:59.464 [main] INFO c.a.n.client.naming - [lambda$initNamespaceForNaming$1,73] - initializer namespace from namespace attribute :null
20:42:59.468 [main] INFO c.a.n.client.naming - [<init>,74] - FailoverDataSource type is class com.alibaba.nacos.client.naming.backups.datasource.DiskFailoverDataSource
20:42:59.473 [main] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.impl.NacosClientAuthServiceImpl success.
20:42:59.473 [main] INFO c.a.n.p.a.s.c.ClientAuthPluginManager - [init,56] - [ClientAuthPluginManager] Load ClientAuthService com.alibaba.nacos.client.auth.ram.RamClientAuthServiceImpl success.
20:42:59.616 [main] INFO c.a.n.c.r.client - [lambda$createClient$0,118] - [RpcClientFactory] create a new rpc client of 7029ce54-e10d-4364-bd06-101eb297d003
20:42:59.619 [main] INFO c.a.n.client.naming - [<init>,109] - Create naming rpc client for uuid->7029ce54-e10d-4364-bd06-101eb297d003
20:42:59.619 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] RpcClient init, ServerListFactory = com.alibaba.nacos.client.naming.core.ServerListManager
20:42:59.619 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Registry connection listener to current client:com.alibaba.nacos.client.naming.remote.gprc.redo.NamingGrpcRedoService
20:42:59.620 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Register server push request handler:com.alibaba.nacos.client.naming.remote.gprc.NamingPushRequestHandler
20:42:59.620 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Try to connect to server on start up, server: {serverIp = '47.116.184.54', server main port = 8848}
20:42:59.621 [main] INFO c.a.n.c.r.c.g.GrpcClient - [createNewManagedChannel,210] - grpc client connection server:47.116.184.54 ip,serverPort:9848,grpcTslConfig:{"sslProvider":"","enableTls":false,"mutualAuthEnable":false,"trustAll":false}
20:42:59.769 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Success to connect to server [47.116.184.54:8848] on start up, connectionId = 1724244181676_139.224.212.27_62378
20:42:59.770 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Notify connected event to listeners.
20:42:59.770 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$ConnectResetRequestHandler
20:42:59.770 [com.alibaba.nacos.client.remote.worker.0] INFO c.a.n.client.naming - [onConnected,90] - Grpc connection connect
20:42:59.770 [main] INFO c.a.n.c.r.client - [printIfInfoEnabled,63] - [7029ce54-e10d-4364-bd06-101eb297d003] Register server push request handler:com.alibaba.nacos.common.remote.client.RpcClient$$Lambda$632/0x0000021a55523c70
20:42:59.772 [main] INFO c.a.n.client.naming - [registerService,133] - [REGISTER-SERVICE] text registering service cloud-etl with instance Instance{instanceId='null', ip='192.168.43.160', port=10005, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={IPv6=[2409:891f:8f05:857f:85b2:f98e:707c:9340], preserved.register.source=SPRING_CLOUD}}
20:42:59.820 [main] INFO c.a.c.n.r.NacosServiceRegistry - [register,76] - nacos registry, DEFAULT_GROUP cloud-etl 192.168.43.160:10005 register finished
20:43:01.014 [main] INFO c.m.c.e.MuYuEtlApplication - [logStarted,56] - Started MuYuEtlApplication in 23.385 seconds (process running for 24.118)
20:43:01.026 [main] INFO c.a.n.c.c.i.CacheData - [initNotifyWarnTimeout,72] - config listener notify warn timeout millis use default 60000 millis
20:43:01.027 [main] INFO c.a.n.c.c.i.CacheData - [<clinit>,99] - nacos.cache.data.init.snapshot = true
20:43:01.028 [main] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl+DEFAULT_GROUP+text
20:43:01.037 [main] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl, group=DEFAULT_GROUP, cnt=1
20:43:01.037 [main] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl, group=DEFAULT_GROUP
20:43:01.039 [main] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl-dev.yml+DEFAULT_GROUP+text
20:43:01.039 [main] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP, cnt=1
20:43:01.039 [main] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl-dev.yml, group=DEFAULT_GROUP
20:43:01.039 [main] INFO c.a.n.c.c.i.ClientWorker - [addCacheDataIfAbsent,416] - [fixed-text-47.116.184.54_8848] [subscribe] cloud-etl.yml+DEFAULT_GROUP+text
20:43:01.039 [main] INFO c.a.n.c.c.i.CacheData - [addListener,236] - [fixed-text-47.116.184.54_8848] [add-listener] ok, tenant=text, dataId=cloud-etl.yml, group=DEFAULT_GROUP, cnt=1
20:43:01.040 [main] INFO c.a.c.n.r.NacosContextRefresher - [registerNacosListener,131] - [Nacos Config] Listening config: dataId=cloud-etl.yml, group=DEFAULT_GROUP
20:43:01.397 [RMI TCP Connection(2)-172.16.0.8] INFO o.a.c.c.C.[.[.[/] - [log,173] - Initializing Spring DispatcherServlet 'dispatcherServlet'
21:09:14.357 [lettuce-eventExecutorLoop-1-1] INFO i.l.c.p.ConnectionWatchdog - [log,171] - Reconnecting, last destination was /172.13.1.1:6379
21:09:21.342 [lettuce-eventExecutorLoop-1-4] INFO i.l.c.p.ConnectionWatchdog - [log,171] - Reconnecting, last destination was 172.13.1.1/<unresolved>:6379
21:09:33.746 [lettuce-eventExecutorLoop-1-6] INFO i.l.c.p.ConnectionWatchdog - [log,171] - Reconnecting, last destination was 172.13.1.1/<unresolved>:6379
21:09:35.729 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connect timed out), for url : http://172.13.1.1:20800/api/registry, content=null]
21:09:38.728 [lettuce-nioEventLoop-6-8] INFO i.l.c.p.ReconnectionHandler - [lambda$null$3,174] - Reconnected to 172.13.1.1/<unresolved>:6379
21:10:07.940 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:10:40.203 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:11:12.443 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:11:44.714 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:12:16.956 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:12:49.167 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:13:21.405 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:13:53.653 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:14:25.875 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:14:58.116 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:15:30.354 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:16:02.604 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:16:34.869 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:17:07.092 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:17:39.293 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:18:11.564 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:18:43.789 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:19:16.083 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:19:48.299 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:20:20.529 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:20:52.780 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:21:24.998 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:21:57.204 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:22:29.424 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:23:01.875 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:23:34.114 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:24:06.368 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:24:38.574 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:25:10.913 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:25:43.195 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:26:15.610 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:26:47.973 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:27:20.369 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:27:52.878 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:28:25.844 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:28:58.044 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:29:30.279 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:30:03.286 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connect timed out), for url : http://172.13.1.1:20800/api/registry, content=null]
21:30:35.544 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Connection refused: no further information), for url : http://172.13.1.1:20800/api/registry, content=null]
21:32:11.252 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,54] - >>>>>>>>>>> xxl-job registry fail, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='cloud-etl', registryValue='http://172.16.0.8:9999/'}, registryResult:ReturnT [code=500, msg=xxl-job remoting error(Read timed out), for url : http://172.13.1.1:20800/api/registry, content=null]
22:22:12.195 [Thread-12] INFO c.x.j.c.s.EmbedServer - [run,91] - >>>>>>>>>>> xxl-job remoting server stop.
22:22:12.434 [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://172.16.0.8:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null]
22:22:12.434 [xxl-job, executor ExecutorRegistryThread] INFO c.x.j.c.t.ExecutorRegistryThread - [run,105] - >>>>>>>>>>> xxl-job, executor registry thread destroy.
22:22:12.434 [SpringApplicationShutdownHook] INFO c.x.j.c.s.EmbedServer - [stop,117] - >>>>>>>>>>> xxl-job remoting server destroy success.
22:22:12.436 [xxl-job, executor JobLogFileCleanThread] INFO c.x.j.c.t.JobLogFileCleanThread - [run,99] - >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.
22:22:12.437 [xxl-job, executor TriggerCallbackThread] INFO c.x.j.c.t.TriggerCallbackThread - [run,98] - >>>>>>>>>>> xxl-job, executor callback thread destroy.
22:22:12.438 [Thread-11] INFO c.x.j.c.t.TriggerCallbackThread - [run,128] - >>>>>>>>>>> xxl-job, executor retry callback thread destroy.
22:22:12.452 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,95] - De-registering from Nacos Server now...
22:22:12.453 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [deregisterService,272] - [DEREGISTER-SERVICE] text deregistering service cloud-etl with instance: Instance{instanceId='null', ip='192.168.43.160', port=10005, weight=1.0, healthy=true, enabled=true, ephemeral=true, clusterName='DEFAULT', serviceName='null', metadata={}}
22:22:12.535 [SpringApplicationShutdownHook] INFO c.a.c.n.r.NacosServiceRegistry - [deregister,115] - De-registration finished.
22:22:12.536 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,254] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown begin
22:22:12.537 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,180] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown begin
22:22:12.537 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,182] - com.alibaba.nacos.client.naming.backups.FailoverReactor do shutdown stop
22:22:12.537 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,256] - com.alibaba.nacos.client.naming.cache.ServiceInfoHolder do shutdown stop
22:22:12.538 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,204] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown begin
22:22:12.538 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,147] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown begin
22:22:12.538 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,149] - com.alibaba.nacos.client.naming.core.ServiceInfoUpdateService do shutdown stop
22:22:12.538 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,218] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown begin
22:22:12.538 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,223] - com.alibaba.nacos.client.naming.core.ServerListManager do shutdown stop
22:22:12.538 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,468] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown begin
22:22:12.538 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,470] - com.alibaba.nacos.client.naming.remote.http.NamingHttpClientProxy do shutdown stop
22:22:12.538 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,487] - Shutdown naming grpc client proxy for uuid->7029ce54-e10d-4364-bd06-101eb297d003
22:22:12.538 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,331] - Shutdown grpc redo service executor java.util.concurrent.ScheduledThreadPoolExecutor@48684456[Running, pool size = 1, active threads = 0, queued tasks = 1, completed tasks = 1979]
22:22:12.539 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,425] - Shutdown rpc client, set status to shutdown
22:22:12.539 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [shutdown,427] - Shutdown client event executor java.util.concurrent.ScheduledThreadPoolExecutor@3dcebe53[Running, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 0]
22:22:12.540 [SpringApplicationShutdownHook] INFO c.a.n.c.r.client - [closeConnection,584] - Close current connection 1724244181676_139.224.212.27_62378
22:22:12.548 [SpringApplicationShutdownHook] INFO c.a.n.c.r.c.g.GrpcClient - [shutdown,187] - Shutdown grpc executor java.util.concurrent.ThreadPoolExecutor@d9f0312[Running, pool size = 3, active threads = 0, queued tasks = 0, completed tasks = 1145]
22:22:12.548 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutDownAndRemove,497] - shutdown and remove naming rpc client for uuid ->7029ce54-e10d-4364-bd06-101eb297d003
22:22:12.549 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialWatcher - [stop,107] - [null] CredentialWatcher is stopped
22:22:12.549 [SpringApplicationShutdownHook] INFO c.a.n.c.a.r.i.CredentialService - [free,91] - [null] CredentialService is freed
22:22:12.550 [SpringApplicationShutdownHook] INFO c.a.n.client.naming - [shutdown,211] - com.alibaba.nacos.client.naming.remote.NamingClientProxyDelegate do shutdown stop
22:22:12.554 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,215] - dynamic-datasource start closing ....
22:22:12.562 [SpringApplicationShutdownHook] INFO c.a.d.p.DruidDataSource - [close,2204] - {dataSource-1} closing ...
22:22:12.581 [SpringApplicationShutdownHook] INFO c.a.d.p.DruidDataSource - [close,2277] - {dataSource-1} closed
22:22:12.581 [SpringApplicationShutdownHook] INFO c.b.d.d.d.DefaultDataSourceDestroyer - [destroy,98] - dynamic-datasource close the datasource named [master] success,
22:22:12.581 [SpringApplicationShutdownHook] INFO c.b.d.d.DynamicRoutingDataSource - [destroy,219] - dynamic-datasource all closed success,bye

4205
logs/cloud-etl/info.log 100644
View File

File diff suppressed because it is too large Load Diff

27
pom.xml 100644
View File

@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-server-parent</artifactId>
<version>3.6.4</version>
</parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-etl-source</artifactId>
<version>1.0.0</version>
<packaging>pom</packaging>
<modules>
<module>cloud-etl-client</module>
<module>cloud-etl-common</module>
<module>cloud-etl-remote</module>
<module>cloud-etl-server</module>
</modules>
</project>