hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ser...@apache.org
Subject svn commit: r1673608 - /hive/branches/llap/ql/src/java/org/apache/hadoop/hive/ql/io/orc/InStream.java
Date Wed, 15 Apr 2015 01:39:28 GMT
Author: sershe
Date: Wed Apr 15 01:39:28 2015
New Revision: 1673608

URL: http://svn.apache.org/r1673608
Log:
HIVE-10333 : LLAP: NPE due to failure to find position (Sergey Shelukhin)

Modified:
    hive/branches/llap/ql/src/java/org/apache/hadoop/hive/ql/io/orc/InStream.java

Modified: hive/branches/llap/ql/src/java/org/apache/hadoop/hive/ql/io/orc/InStream.java
URL: http://svn.apache.org/viewvc/hive/branches/llap/ql/src/java/org/apache/hadoop/hive/ql/io/orc/InStream.java?rev=1673608&r1=1673607&r2=1673608&view=diff
==============================================================================
--- hive/branches/llap/ql/src/java/org/apache/hadoop/hive/ql/io/orc/InStream.java (original)
+++ hive/branches/llap/ql/src/java/org/apache/hadoop/hive/ql/io/orc/InStream.java Wed Apr
15 01:39:28 2015
@@ -697,9 +697,10 @@ public abstract class InStream extends I
           toDecompress = new ArrayList<ProcCacheChunk>();
           toRelease = (zcr == null) ? null : new ArrayList<ByteBuffer>();
         }
-        lastCached = addOneCompressionBuffer(bc, zcr, bufferSize,
+        ProcCacheChunk newCached = addOneCompressionBuffer(bc, zcr, bufferSize,
             cache, streamBuffer.cacheBuffers, toDecompress, toRelease);
-        next = (lastCached != null) ? lastCached.next : null;
+        lastCached = (newCached == null) ? lastCached : newCached;
+        next = (newCached != null) ? newCached.next : null;
         currentCOffset = (next != null) ? next.getOffset() : -1;
       }
 



Mime
View raw message