diff --git a/fe/src/main/java/org/apache/doris/planner/OlapTableSink.java b/fe/src/main/java/org/apache/doris/planner/OlapTableSink.java index f330b0403a..b32e511951 100644 --- a/fe/src/main/java/org/apache/doris/planner/OlapTableSink.java +++ b/fe/src/main/java/org/apache/doris/planner/OlapTableSink.java @@ -198,7 +198,9 @@ public class OlapTableSink extends DataSink { } case RANDOM: { for (Column column : table.getBaseSchema()) { - distColumns.add(column.getName()); + if (column.isKey()) { + distColumns.add(column.getName()); + } } break; }