fix fe bug.

apache · Jan 13, 2025 · d627a57 · d627a57
1 parent 2928660
commit d627a57
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/BindSink.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/analysis/BindSink.java
@@ -692,7 +692,7 @@ private static Map<String, NamedExpression> getDictColumnToOutput(
         Map<String, NamedExpression> columnToOutput = Maps.newTreeMap(String.CASE_INSENSITIVE_ORDER);
         // for sink columns D|B|A, link them with child's outputs
         for (Column column : sinkSchema) {
-            if (upstreamOutputs.containsKey(column)) {
+            if (upstreamOutputs.containsKey(column.getName())) {
                 // TODO: for dictionary the type should be exactly same. try to remove TypeCoercion here
                 Alias output = new Alias(TypeCoercionUtils.castIfNotSameType(upstreamOutputs.get(column.getName()),
                         DataType.fromCatalogType(column.getType())), column.getName());

diff --git a/.../src/main/java/org/apache/doris/nereids/trees/plans/commands/CreateDictionaryCommand.java b/.../src/main/java/org/apache/doris/nereids/trees/plans/commands/CreateDictionaryCommand.java
@@ -72,7 +72,7 @@ public void run(ConnectContext ctx, StmtExecutor executor) {
             LOG.info("Created dictionary {} in {} from {}", createDictionaryInfo.getDictName(),
                     createDictionaryInfo.getDbName(), createDictionaryInfo.getSourceTableName());
         } catch (Exception e) {
-            LOG.warn("Failed to create dictionary: {}", e.getMessage());
+            LOG.warn("Failed to create dictionary: {}", e);
             throw new AnalysisException("Failed to create dictionary: " + e.getMessage());
         }
     }