kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shaofeng...@apache.org
Subject kylin git commit: minor, fix create count source table error when using beeline
Date Tue, 19 Jul 2016 03:02:56 GMT
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 <shaofengshi@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 <liuyiming.vip@gmail.com>
Authored: Tue Jul 19 10:59:57 2016 +0800
Committer: shaofengshi <shaofengshi@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();
     }


Mime
View raw message