diff --git a/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/flink/FlinkVertex.java b/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/flink/FlinkVertex.java index 1f82788..740cddd 100644 --- a/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/flink/FlinkVertex.java +++ b/service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/flink/FlinkVertex.java @@ -11,6 +11,7 @@ import org.eclipse.collections.api.list.ImmutableList; * @date 2023-05-04 */ public class FlinkVertex { + @JsonAlias({"jid", "id"}) private String jid; private String name; private String state; @@ -23,6 +24,7 @@ public class FlinkVertex { private Tasks tasks; @JsonAlias("maxParallelism") private Integer maxParallelism; + private Integer parallelism; private Long now; private Timestamps timestamps; @JsonAlias("vertices")