Repository: kylin Updated Branches: refs/heads/stream_m1 3202cb259 -> 32a08f8bf (forced update)
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/stream_m1 Commit: cdcde050d18ae72408f91cf2d3dc894a5798d319 Parents: c965250 Author: shaofengshi <shaofeng...@apache.org> Authored: Wed Jun 15 16:46:37 2016 +0800 Committer: shaofengshi <shaofeng...@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());
