Repository: trafodion Updated Branches: refs/heads/master 6dbea7e87 -> 1650c784e
[TRAFODION-3171] Refactor Hive sequence file reading to use the new implementation Fix for hive/TEST006 failure in daily build Project: http://git-wip-us.apache.org/repos/asf/trafodion/repo Commit: http://git-wip-us.apache.org/repos/asf/trafodion/commit/02ad26b8 Tree: http://git-wip-us.apache.org/repos/asf/trafodion/tree/02ad26b8 Diff: http://git-wip-us.apache.org/repos/asf/trafodion/diff/02ad26b8 Branch: refs/heads/master Commit: 02ad26b8e1384c156ac1d877b28b52d0af6b8931 Parents: a9bbe12 Author: selvaganesang <[email protected]> Authored: Mon Aug 27 18:23:14 2018 +0000 Committer: selvaganesang <[email protected]> Committed: Mon Aug 27 18:23:14 2018 +0000 ---------------------------------------------------------------------- core/sql/src/main/java/org/trafodion/sql/HDFSClient.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/trafodion/blob/02ad26b8/core/sql/src/main/java/org/trafodion/sql/HDFSClient.java ---------------------------------------------------------------------- diff --git a/core/sql/src/main/java/org/trafodion/sql/HDFSClient.java b/core/sql/src/main/java/org/trafodion/sql/HDFSClient.java index 39e4c9a..4f06e7b 100644 --- a/core/sql/src/main/java/org/trafodion/sql/HDFSClient.java +++ b/core/sql/src/main/java/org/trafodion/sql/HDFSClient.java @@ -264,6 +264,7 @@ public class HDFSClient int sequenceFileRead(int readLenRemain) throws IOException { boolean eof = false; + boolean nextValue; byte[] byteArray; int readLen; int totalReadLen = 0; @@ -273,7 +274,11 @@ public class HDFSClient while (!eof && lenRemain > 0) { try { tempPos = reader_.getPosition(); - eof = reader_.next(key_, value_); + nextValue = reader_.next(key_, value_); + if (!nextValue) { + eof = true; + break; + } } catch (java.io.EOFException e) {
