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

    https://github.com/apache/carbondata/pull/2313#discussion_r189246763
  
    --- Diff: 
core/src/main/java/org/apache/carbondata/core/datastore/compression/SnappyCompressor.java
 ---
    @@ -135,52 +136,52 @@ public String getName() {
           return Snappy.uncompressIntArray(compInput);
         } catch (IOException e) {
           LOGGER.error(e, e.getMessage());
    +      throw new RuntimeException(e);
         }
    -    return null;
       }
     
       @Override public int[] unCompressInt(byte[] compInput, int offset, int 
length) {
         try {
           return Snappy.uncompressIntArray(compInput, offset, length);
         } catch (IOException e) {
           LOGGER.error(e, e.getMessage());
    +      throw new RuntimeException(e);
         }
    -    return null;
       }
     
       @Override public byte[] compressLong(long[] unCompInput) {
         try {
           return Snappy.compress(unCompInput);
         } catch (IOException e) {
           LOGGER.error(e, e.getMessage());
    -      return null;
    +      throw new RuntimeException(e);
         }
       }
     
    -  @Override public long[] unCompressLong(byte[] compInput) {
    +  @Override public long[] uncompresslong(byte[] compinput) {
    --- End diff --
    
    fixed


---

Reply via email to