[TRAFODION-3171] Refactor Hive sequence file reading to use the new i…

…mplementation Changes possibly fix the hive/TEST006 failure in daily build.
apache · Aug 8, 2018 · 39d7110 · 39d7110
1 parent affc9db
commit 39d7110
Showing 1 changed file with 6 additions and 2 deletions.
diff --git 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 void scheduleHdfsScanRange(int bufNo, int bytesCompleted) throws IOExcept
          } catch (EOFException e)
          {
             // Skip this range
-            currRange_++; 
-            scheduleHdfsScanRange(bufNo, 0); 
+            if (currRange_ == (hdfsScanRanges_.length-1)) 
+                scanCompleted_ = true;
+            else {
+               currRange_++; 
+               scheduleHdfsScanRange(bufNo, 0); 
+            }
          } 
       }
    }