diff --git a/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/JobAndMetas.java b/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/JobAndMetas.java index 86221f1..30e8ce3 100644 --- a/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/JobAndMetas.java +++ b/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/info/JobAndMetas.java @@ -3,21 +3,22 @@ package com.lanyuanxiaoyao.service.configuration.entity.info; import com.eshore.odcp.hudi.connector.entity.FlinkJob; import com.eshore.odcp.hudi.connector.entity.TableMeta; import java.util.List; +import org.eclipse.collections.api.list.ImmutableList; /** * flink job 和 table meta * * @author lanyuanxiaoyao - * @date 2023-04-24 + * @date 2023-12-27 */ public class JobAndMetas { private FlinkJob job; - private List metas; + private ImmutableList metas; public JobAndMetas() { } - public JobAndMetas(FlinkJob job, List metas) { + public JobAndMetas(FlinkJob job, ImmutableList metas) { this.job = job; this.metas = metas; } @@ -26,7 +27,7 @@ public class JobAndMetas { return job; } - public List getMetas() { + public ImmutableList getMetas() { return metas; } 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 f90f404..96da3d1 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 @@ -210,7 +210,7 @@ public class InfoService { @Cacheable(value = "job-metas", sync = true) @Retryable(Throwable.class) public ImmutableList jobAndMetas() { - return databaseService.findAllFlinkJob().collect(job -> new JobAndMetas(job, databaseService.findTableMeta(job.getId()).toList())); + return databaseService.findAllFlinkJob().collect(job -> new JobAndMetas(job, databaseService.findTableMeta(job.getId()))); } @Cacheable(value = "flink-jobs", sync = true)