Repository: trafodion Updated Branches: refs/heads/master f38a1006b -> c1aa0e6f4
[TRAFODION-3171] Refactor Hive sequence file reading to use the new implementation Changes possibly fix the 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/39d71103 Tree: http://git-wip-us.apache.org/repos/asf/trafodion/tree/39d71103 Diff: http://git-wip-us.apache.org/repos/asf/trafodion/diff/39d71103 Branch: refs/heads/master Commit: 39d71103aaed3ce10a518533f296c35201cf3bea Parents: affc9db Author: selvaganesang <selva.govindara...@esgyn.com> Authored: Wed Aug 8 23:06:58 2018 +0000 Committer: selvaganesang <selva.govindara...@esgyn.com> Committed: Wed Aug 8 23:06:58 2018 +0000 ---------------------------------------------------------------------- core/sql/src/main/java/org/trafodion/sql/HdfsScan.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/trafodion/blob/39d71103/core/sql/src/main/java/org/trafodion/sql/HdfsScan.java ---------------------------------------------------------------------- diff --git a/core/sql/src/main/java/org/trafodion/sql/HdfsScan.java b/core/sql/src/main/java/org/trafodion/sql/HdfsScan.java index 4d7b90d..7d813eb 100644 --- a/core/sql/src/main/java/org/trafodion/sql/HdfsScan.java +++ b/core/sql/src/main/java/org/trafodion/sql/HdfsScan.java @@ -177,8 +177,12 @@ public class HdfsScan } catch (EOFException e) { // Skip this range - currRange_++; - scheduleHdfsScanRange(bufNo, 0); + if (currRange_ == (hdfsScanRanges_.length-1)) + scanCompleted_ = true; + else { + currRange_++; + scheduleHdfsScanRange(bufNo, 0); + } } } }
