diff --git a/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java b/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java
index 22ad2e0d2..50b0e10c5 100644
--- a/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java
+++ b/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java
@@ -889,6 +889,7 @@ else if (this.handle == 0)
             {
                 if (dataLen == 0)
                 {
+                    dataLen = dis.readInt(); // need to read addl int here ...
                     close();
                     return 0;
                 }