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/06/15 08:47:09 UTC
kylin git commit: remove redundant code
Repository: kylin
Updated Branches:
refs/heads/master c965250b4 -> cdcde050d
remove redundant code
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/cdcde050
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/cdcde050
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/cdcde050
Branch: refs/heads/master
Commit: cdcde050d18ae72408f91cf2d3dc894a5798d319
Parents: c965250
Author: shaofengshi <sh...@apache.org>
Authored: Wed Jun 15 16:46:37 2016 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Wed Jun 15 16:47:02 2016 +0800
----------------------------------------------------------------------
.../main/java/org/apache/kylin/source/hive/HiveMRInput.java | 7 +------
1 file changed, 1 insertion(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/cdcde050/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 76dda34..a444903 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
@@ -112,12 +112,7 @@ public class HiveMRInput implements IMRInput {
final String cubeName = CubingExecutableUtil.getCubeName(jobFlow.getParams());
final String rowCountOutputDir = JobBuilderSupport.getJobWorkingDir(conf, jobFlow.getId()) + "/row_count";
- try {
- FileSystem fs = FileSystem.get(HadoopUtil.getCurrentConfiguration());
- fs.mkdirs(new Path(rowCountOutputDir));
- } catch (IOException e) {
- throw new RuntimeException("Failed to create HDFS dir " + rowCountOutputDir, e);
- }
+
jobFlow.addTask(createCountHiveTableStep(conf, flatHiveTableDesc, jobFlow.getId(), rowCountOutputDir));
jobFlow.addTask(createFlatHiveTableStep(conf, flatHiveTableDesc, jobFlow.getId(), cubeName, rowCountOutputDir));
AbstractExecutable task = createLookupHiveViewMaterializationStep(jobFlow.getId());