Github user manishgupta88 commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/2142#discussion_r180646899
  
    --- Diff: 
processing/src/main/java/org/apache/carbondata/processing/merger/CompactionResultSortProcessor.java
 ---
    @@ -165,8 +168,12 @@ public boolean execute(List<RawResultIterator> 
resultIteratorList) {
             readAndLoadDataFromSortTempFiles();
           }
           isCompactionSuccess = true;
    -    } catch (Exception e) {
    +    } catch (BadRecordFoundException e) {
    +      LOGGER.error(e, "Compaction failed: " + e.getMessage());
    +    }
    +    catch (Exception e) {
           LOGGER.error(e, "Compaction failed: " + e.getMessage());
    +      throw new SparkException(e.getMessage());
    --- End diff --
    
    Remove throwing sparkException from everywhere in the code


---

Reply via email to