fix(flink-query): 修复算子 id 没有获取到的问题

2023-05-06 10:49:15 +08:00
parent 47b3656d73
commit 71df97203d
1 changed files with 2 additions and 0 deletions
--- 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")