Repository: kylin Updated Branches: refs/heads/master 1adb54228 -> 36eec4122
KYLIN-1912: Fix Beeline build intermediate statement issue Signed-off-by: lidongsjtu <lid...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/36eec412 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/36eec412 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/36eec412 Branch: refs/heads/master Commit: 36eec41221614ca89d50a3388db4fa7ab3bfc5a3 Parents: 1adb542 Author: Yiming Liu <liuyiming....@gmail.com> Authored: Fri Jul 22 07:48:48 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Fri Jul 22 09:12:42 2016 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/kylin/source/hive/HiveCmdBuilder.java | 4 ++++ .../src/main/java/org/apache/kylin/source/hive/HiveMRInput.java | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/36eec412/source-hive/src/main/java/org/apache/kylin/source/hive/HiveCmdBuilder.java ---------------------------------------------------------------------- diff --git a/source-hive/src/main/java/org/apache/kylin/source/hive/HiveCmdBuilder.java b/source-hive/src/main/java/org/apache/kylin/source/hive/HiveCmdBuilder.java index 6316b9c..5a5b4e0 100644 --- a/source-hive/src/main/java/org/apache/kylin/source/hive/HiveCmdBuilder.java +++ b/source-hive/src/main/java/org/apache/kylin/source/hive/HiveCmdBuilder.java @@ -20,6 +20,7 @@ package org.apache.kylin.source.hive; import java.io.BufferedWriter; import java.io.File; +import java.io.FileReader; import java.io.FileWriter; import java.io.IOException; import java.util.ArrayList; @@ -78,6 +79,9 @@ public class HiveCmdBuilder { buf.append(tmpHql.getAbsolutePath()); logger.info("The statements to execute in beeline: \n" + hqlBuf); + if (logger.isDebugEnabled()) { + logger.debug("THe SQL to execute in beeline: \n" + IOUtils.toString(new FileReader(tmpHql))); + } } catch (IOException e) { throw new RuntimeException(e); } finally { http://git-wip-us.apache.org/repos/asf/kylin/blob/36eec412/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java ---------------------------------------------------------------------- diff --git a/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java b/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java index 72c84fc..0c969f2 100644 --- a/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java +++ b/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java @@ -186,7 +186,7 @@ public class HiveMRInput implements IMRInput { StringBuilder hiveInitBuf = new StringBuilder(); hiveInitBuf.append(JoinedFlatTable.generateHiveSetStatements(conf)); - final String useDatabaseHql = "USE " + conf.getConfig().getHiveDatabaseForIntermediateTable() + ";"; + final String useDatabaseHql = "USE " + conf.getConfig().getHiveDatabaseForIntermediateTable() + ";\n"; final String dropTableHql = JoinedFlatTable.generateDropTableStatement(flatTableDesc); final String createTableHql = JoinedFlatTable.generateCreateTableStatement(flatTableDesc, JobBuilderSupport.getJobWorkingDir(conf, jobId)); String insertDataHqls;
