diff --git a/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsUtil.java b/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsUtil.java index 8a8055f72c..1d50bbca42 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsUtil.java +++ b/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsUtil.java @@ -37,7 +37,6 @@ import org.apache.doris.analysis.RangePartitionDesc; import org.apache.doris.analysis.SlotRef; import org.apache.doris.catalog.ArrayType; import org.apache.doris.catalog.Column; -import org.apache.doris.catalog.Env; import org.apache.doris.catalog.ScalarType; import org.apache.doris.catalog.Type; import org.apache.doris.common.AnalysisException; @@ -378,7 +377,7 @@ public class EsUtil { column.setName(key); column.setIsKey(true); column.setIsAllowNull(true); - column.setUniqueId((int) Env.getCurrentEnv().getNextId()); + column.setUniqueId(-1); if (arrayFields.contains(key)) { column.setType(ArrayType.create(type, true)); } else {