diff --git a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/BackendV2.java b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/BackendV2.java index 858408a1..544be01c 100644 --- a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/BackendV2.java +++ b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/BackendV2.java @@ -38,6 +38,7 @@ public void setRows(List rows) { this.backends = rows; } + @JsonIgnoreProperties(ignoreUnknown = true) public static class BackendRowV2 implements Cloneable{ public BackendRowV2(){ diff --git a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Field.java b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Field.java index 53c622bd..0b95ffbe 100644 --- a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Field.java +++ b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Field.java @@ -17,8 +17,11 @@ package org.apache.doris.spark.rest.models; +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; + import java.util.Objects; +@JsonIgnoreProperties(ignoreUnknown = true) public class Field { private String name; private String type; diff --git a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/QueryPlan.java b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/QueryPlan.java index 0ab580ef..ec0ac646 100644 --- a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/QueryPlan.java +++ b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/QueryPlan.java @@ -17,9 +17,12 @@ package org.apache.doris.spark.rest.models; +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; + import java.util.Map; import java.util.Objects; +@JsonIgnoreProperties(ignoreUnknown = true) public class QueryPlan { private int status; private String opaqued_query_plan; diff --git a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Schema.java b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Schema.java index ebf385b5..f5a9f995 100644 --- a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Schema.java +++ b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Schema.java @@ -17,10 +17,13 @@ package org.apache.doris.spark.rest.models; +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; + import java.util.ArrayList; import java.util.List; import java.util.Objects; +@JsonIgnoreProperties(ignoreUnknown = true) public class Schema { private int status = 0; diff --git a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Tablet.java b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Tablet.java index 050bffce..b5275b1a 100644 --- a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Tablet.java +++ b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/rest/models/Tablet.java @@ -17,9 +17,12 @@ package org.apache.doris.spark.rest.models; +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; + import java.util.List; import java.util.Objects; +@JsonIgnoreProperties(ignoreUnknown = true) public class Tablet { private List routings; private int version;