From 51325424b13a7aa090f5a85cc7bdfa08efe6ffff Mon Sep 17 00:00:00 2001 From: Yiming Liu Date: Fri, 22 Jul 2016 07:48:48 +0800 Subject: [PATCH] KYLIN-1912: Fix Beeline build intermediate statement issue --- .../src/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(-) 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 { 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; -- 2.7.4 (Apple Git-66)