KYLIN-2165 use cube specific configs for hive job and use lowercase tablename

Signed-off-by: gaodayue <[email protected]>

Author: gaodayue

core-cube/src/main/java/org/apache/kylin/cube/model/CubeJoinedFlatTableDesc.java

@@ -63,9 +63,9 @@ private CubeJoinedFlatTableDesc(CubeDesc cubeDesc, CubeSegment cubeSegment /* ca
 
     protected String makeTableName(CubeDesc cubeDesc, CubeSegment cubeSegment) {
         if (cubeSegment == null) {
-            return "kylin_intermediate_" + cubeDesc.getName();
+            return "kylin_intermediate_" + cubeDesc.getName().toLowerCase();
         } else {
-            return "kylin_intermediate_" + cubeDesc.getName() + "_" + cubeSegment.getUuid().replaceAll("-", "_");
+            return "kylin_intermediate_" + cubeDesc.getName().toLowerCase() + "_" + cubeSegment.getUuid().replaceAll("-", "_");
         }
     }
 

source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java

@@ -127,19 +127,19 @@ public String[] parseMapperInput(Object mapperInput) {
 
     public static class BatchCubingInputSide implements IMRBatchCubingInputSide {
 
-        final JobEngineConfig conf;
+        JobEngineConfig conf;
         final IJoinedFlatTableDesc flatDesc;
         String hiveViewIntermediateTables = "";
 
         public BatchCubingInputSide(IJoinedFlatTableDesc flatDesc) {
-            this.conf = new JobEngineConfig(KylinConfig.getInstanceFromEnv());
             this.flatDesc = flatDesc;
         }
 
         @Override
         public void addStepPhase1_CreateFlatTable(DefaultChainedExecutable jobFlow) {
             final String cubeName = CubingExecutableUtil.getCubeName(jobFlow.getParams());
             final KylinConfig kylinConfig = CubeManager.getInstance(conf.getConfig()).getCube(cubeName).getConfig();
+            this.conf = new JobEngineConfig(kylinConfig);
 
             // create flat table first, then count and redistribute
             jobFlow.addTask(createFlatHiveTableStep(conf, flatDesc, jobFlow.getId(), cubeName));