You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2016/07/19 03:02:56 UTC
kylin git commit: minor,
fix create count source table error when using beeline
Repository: kylin
Updated Branches:
refs/heads/v1.5.3-release 837857776 -> 55f5ea3ff
minor, fix create count source table error when using beeline
Signed-off-by: shaofengshi <sh...@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/v1.5.3-release
Commit: 55f5ea3ff981d4f051cbcfa53db6bc54b97aab0d
Parents: 8378577
Author: Yiming Liu <li...@gmail.com>
Authored: Tue Jul 19 10:59:57 2016 +0800
Committer: shaofengshi <sh...@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();
}