From 45fa2fc56b2969f05e2b4e3150876cd029b54261 Mon Sep 17 00:00:00 2001 From: Jibing-Li <64681310+Jibing-Li@users.noreply.github.com> Date: Fri, 25 Nov 2022 16:13:16 +0800 Subject: [PATCH] [fix](multi catalog)Use -1 as external es table column id instead of uniq id (#14557) Using cache to store external table columns, doesn't persist uniq id for external columns anymore. So use -1 as column id for ES external table. Avoid non-master FE trying to get uniq id problem. The problem will cause non-master FE fail to write bdbje. --- .../java/org/apache/doris/external/elasticsearch/EsUtil.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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 {