diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/InfoQueryApplication.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/InfoQueryApplication.java index 468cf58..6701274 100644 --- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/InfoQueryApplication.java +++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/InfoQueryApplication.java @@ -21,7 +21,6 @@ import org.springframework.scheduling.annotation.EnableScheduling; @SpringBootApplication( scanBasePackages = { "com.lanyuanxiaoyao.service", - "com.eshore.odcp.hudi.connector.utils.database" }, exclude = {GsonAutoConfiguration.class} ) diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/FlinkJobService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/FlinkJobService.java index 7b06773..ac82e09 100644 --- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/FlinkJobService.java +++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/FlinkJobService.java @@ -33,7 +33,7 @@ public class FlinkJobService extends BaseService { private static final Logger logger = LoggerFactory.getLogger(FlinkJobService.class); private final JdbcTemplate mysqlJdbcTemplate; - public FlinkJobService(JdbcTemplate mysqlJdbcTemplate, TransactionTemplate mysqlTransactionTemplate, SQLLoggerProvider.SQLLogger sqlLogger) { + public FlinkJobService(JdbcTemplate mysqlJdbcTemplate) { this.mysqlJdbcTemplate = mysqlJdbcTemplate; } diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java index f287eca..837913c 100644 --- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java +++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/InfoService.java @@ -37,7 +37,7 @@ public class InfoService extends BaseService { private final FlinkJobService flinkJobService; private final TableMetaService tableMetaService; - public InfoService(JdbcTemplate mysqlJdbcTemplate, TransactionTemplate mysqlTransactionTemplate, SQLLoggerProvider.SQLLogger sqlLogger, FlinkJobService flinkJobService, TableMetaService tableMetaService) { + public InfoService(JdbcTemplate mysqlJdbcTemplate, TransactionTemplate mysqlTransactionTemplate, FlinkJobService flinkJobService, TableMetaService tableMetaService) { this.mysqlJdbcTemplate = mysqlJdbcTemplate; this.mysqlTransactionTemplate = mysqlTransactionTemplate; this.flinkJobService = flinkJobService; diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java index b758671..c4f9f4e 100644 --- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java +++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/TableMetaService.java @@ -44,7 +44,7 @@ public class TableMetaService extends BaseService { private final JdbcTemplate mysqlJdbcTemplate; private final FlinkJobService flinkJobService; - public TableMetaService(JdbcTemplate mysqlJdbcTemplate, TransactionTemplate mysqlTransactionTemplate, SQLLoggerProvider.SQLLogger sqlLogger, FlinkJobService flinkJobService) { + public TableMetaService(JdbcTemplate mysqlJdbcTemplate, FlinkJobService flinkJobService) { this.mysqlJdbcTemplate = mysqlJdbcTemplate; this.flinkJobService = flinkJobService; }