From bbb3fdef8ca2b52622a90526354384bb0fa8381e Mon Sep 17 00:00:00 2001 From: Mingyu Chen Date: Fri, 11 Oct 2019 20:07:25 +0800 Subject: [PATCH] Fix bug that OlapTableSink use invalid column as distribution column for RANDOM distribution table. (#1956) RANDOM distribution is deprecated long time ago, this is just for compatibility and bug fix. --- fe/src/main/java/org/apache/doris/planner/OlapTableSink.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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; }