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/55f5ea3f Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/55f5ea3f Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/55f5ea3f Branch: refs/heads/1.5.x-CDH5.7 Commit: 55f5ea3ff981d4f051cbcfa53db6bc54b97aab0d Parents: 8378577 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:02:47 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/55f5ea3f/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(); }
