commit 16046cce5609fc1d505da72901c8fecdf708d844
author edi_bice <edi_bice@yahoo.com> Thu Feb 18 17:06:12 2016 -0500
committer Gianmarco De Francisci Morales <gdfm@apache.org> Tue Apr 19 11:33:42 2016 +0300
tree ad403ecadb55770ba2ffca39e11ec1b248804ed1
parent ebb35163f36434a632d64d95706166fc9a6eaee7

SAMOA-58: A tentative solution to issue described in:

https://issues.apache.org/jira/browse/SAMOA-58

samoa-api/src/main/java/org/apache/samoa/streams/FileStream.java

diff --git a/samoa-api/src/main/java/org/apache/samoa/streams/FileStream.java b/samoa-api/src/main/java/org/apache/samoa/streams/FileStream.java
index eece541..2998b22 100644
--- a/samoa-api/src/main/java/org/apache/samoa/streams/FileStream.java
+++ b/samoa-api/src/main/java/org/apache/samoa/streams/FileStream.java
@@ -80,7 +80,16 @@
 
   @Override
   public boolean hasMoreInstances() {
-    return !this.hitEndOfStream;
+    if (this.hitEndOfStream) {
+      if (getNextFileReader()) {
+        this.hitEndOfStream = false;
+        return hasMoreInstances();
+      } else {
+        return false;
+      }
+    } else {
+      return true;
+    }
   }
 
   @Override