You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ay...@apache.org on 2023/04/19 23:00:34 UTC

[hive] branch master updated: HIVE-27128: Exception "Can't finish byte read from uncompressed stream DATA position" when querying ORC table. (#4233). (Dmitriy Fingerman, reviewed by Ayush Saxena, Steve Carlin, Attila Turóczy)

This is an automated email from the ASF dual-hosted git repository.

ayushsaxena pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new 79918cea27c HIVE-27128: Exception "Can't finish byte read from uncompressed stream DATA position" when querying ORC table. (#4233). (Dmitriy Fingerman, reviewed by Ayush Saxena, Steve Carlin, Attila Turóczy)
79918cea27c is described below

commit 79918cea27cb90f569998f02d53f2a4d667aac04
Author: Dmitriy Fingerman <dm...@gmail.com>
AuthorDate: Wed Apr 19 19:00:27 2023 -0400

    HIVE-27128: Exception "Can't finish byte read from uncompressed stream DATA position" when querying ORC table. (#4233). (Dmitriy Fingerman, reviewed by Ayush Saxena, Steve Carlin, Attila Turóczy)
---
 .../hadoop/hive/ql/io/orc/encoded/SettableUncompressedStream.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/encoded/SettableUncompressedStream.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/encoded/SettableUncompressedStream.java
index 8fc4cdaff0d..f0185a77bcc 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/encoded/SettableUncompressedStream.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/encoded/SettableUncompressedStream.java
@@ -29,7 +29,7 @@ public class SettableUncompressedStream extends InStream.UncompressedStream {
   }
 
   public void setBuffers(DiskRangeInfo diskRangeList) {
-    reset(diskRangeList.getDiskRanges());
+    reset(diskRangeList.getDiskRanges(), diskRangeList.getTotalLength());
     setOffset(diskRangeList.getDiskRanges());
   }