Repository: kylin Updated Branches: refs/heads/KYLIN-1971 d3ac35420 -> 6feb5bd1d
bug fix Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/6feb5bd1 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/6feb5bd1 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/6feb5bd1 Branch: refs/heads/KYLIN-1971 Commit: 6feb5bd1d393c57857faa7baea615611d722e1fa Parents: d3ac354 Author: Yang Li <liy...@apache.org> Authored: Sun Nov 6 19:03:57 2016 +0800 Committer: Yang Li <liy...@apache.org> Committed: Sun Nov 6 19:03:57 2016 +0800 ---------------------------------------------------------------------- core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/6feb5bd1/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java ---------------------------------------------------------------------- diff --git a/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java b/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java index af9c948..61b5b11 100644 --- a/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java +++ b/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java @@ -169,7 +169,7 @@ public class JoinedFlatTable { private static void appendDistributeStatement(StringBuilder sql, TblColRef redistCol) { if (redistCol != null) { - sql.append(" DISTRIBUTE BY ").append(redistCol.getTableAlias() + "." + redistCol.getName()).append(";\n"); + sql.append(" DISTRIBUTE BY ").append(colName(redistCol)).append(";\n"); } else { sql.append(" DISTRIBUTE BY RAND()").append(";\n"); }
