Github user ajantha-bhat commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/2131#discussion_r179360518
  
    --- Diff: 
hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonTableInputFormat.java
 ---
    @@ -128,12 +134,18 @@ protected CarbonTable 
getOrCreateCarbonTable(Configuration configuration) throws
       @Override
       public List<InputSplit> getSplits(JobContext job) throws IOException {
         AbsoluteTableIdentifier identifier = 
getAbsoluteTableIdentifier(job.getConfiguration());
    -    LoadMetadataDetails[] loadMetadataDetails = SegmentStatusManager
    -        
.readTableStatusFile(CarbonTablePath.getTableStatusFilePath(identifier.getTablePath()));
    +
         CarbonTable carbonTable = 
getOrCreateCarbonTable(job.getConfiguration());
         if (null == carbonTable) {
           throw new IOException("Missing/Corrupt schema file for table.");
         }
    +    this.readCommittedScope = getReadCommitted(job, identifier);
    --- End diff --
    
    done


---

Reply via email to