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.
This commit is contained in:
Mingyu Chen
2019-10-11 20:07:25 +08:00
committed by lichaoyong
parent 71731b25f4
commit bbb3fdef8c

View File

@ -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;
}