From 71df97203d69cffd1905dc0b01b66abe2d04868d Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Sat, 6 May 2023 10:49:15 +0800 Subject: [PATCH] =?UTF-8?q?fix(flink-query):=20=E4=BF=AE=E5=A4=8D=E7=AE=97?= =?UTF-8?q?=E5=AD=90=20id=20=E6=B2=A1=E6=9C=89=E8=8E=B7=E5=8F=96=E5=88=B0?= =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/configuration/entity/flink/FlinkVertex.java | 2 ++ 1 file changed, 2 insertions(+) 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")