[TRAFODION-3171] Refactor Hive sequence file reading to use the new implementation
Fix to resolve the issue highlighted in the review comment Project: http://git-wip-us.apache.org/repos/asf/trafodion/repo Commit: http://git-wip-us.apache.org/repos/asf/trafodion/commit/abbfe856 Tree: http://git-wip-us.apache.org/repos/asf/trafodion/tree/abbfe856 Diff: http://git-wip-us.apache.org/repos/asf/trafodion/diff/abbfe856 Branch: refs/heads/master Commit: abbfe85683c299be35b79f64b90d90f7c253dc51 Parents: 6165e6b Author: selvaganesang <selva.govindara...@esgyn.com> Authored: Fri Aug 3 17:27:27 2018 +0000 Committer: selvaganesang <selva.govindara...@esgyn.com> Committed: Fri Aug 3 17:27:27 2018 +0000 ---------------------------------------------------------------------- core/sql/src/main/java/org/trafodion/sql/HDFSClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/trafodion/blob/abbfe856/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 8a14b61..c04c256 100644 --- a/core/sql/src/main/java/org/trafodion/sql/HDFSClient.java +++ b/core/sql/src/main/java/org/trafodion/sql/HDFSClient.java @@ -280,7 +280,7 @@ public class HDFSClient } byteArray = ((Text)value_).getBytes(); readLen = ((Text)value_).getLength(); - if (readLen <= lenRemain) { + if ((readLen+1) <= lenRemain) { buf_.put(byteArray, 0, readLen); buf_.put(recDelimiter_);
