Repository: kylin Updated Branches: refs/heads/master faa952327 -> 960bb953c
minor, fix create count source table error when using beeline Signed-off-by: shaofengshi <shaofeng...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/960bb953 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/960bb953 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/960bb953 Branch: refs/heads/master Commit: 960bb953c62366696fc01e4352e4b228e2ea1571 Parents: faa9523 Author: Yiming Liu <liuyiming....@gmail.com> Authored: Tue Jul 19 10:59:57 2016 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Tue Jul 19 11:03:12 2016 +0800 ---------------------------------------------------------------------- core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/960bb953/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 31c92b6..1b8df14 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 @@ -137,8 +137,8 @@ public class JoinedFlatTable { final Map<String, String> tableAliasMap = buildTableAliasMap(intermediateTableDesc.getDataModel()); final StringBuilder sql = new StringBuilder(); final String factTbl = intermediateTableDesc.getDataModel().getFactTable(); - sql.append("dfs -mkdir -p " + outputDir + ";"); - sql.append("INSERT OVERWRITE DIRECTORY '" + outputDir + "' SELECT count(*) from " + factTbl + " " + tableAliasMap.get(factTbl) + "\n"); + sql.append("dfs -mkdir -p " + outputDir + ";\n"); + sql.append("INSERT OVERWRITE DIRECTORY '" + outputDir + "' SELECT count(*) FROM " + factTbl + " " + tableAliasMap.get(factTbl) + "\n"); appendWhereStatement(intermediateTableDesc, sql, tableAliasMap); return sql.toString(); }
