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 372bdce1e..22ad2e0d2 100644
--- a/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java
+++ b/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java
@@ -825,6 +825,9 @@ private int startFetch()
             {
                 try
                 {
+                    // Read handle before closing
+                    this.dis.readInt();
+
                     close();
                 }
                 catch (IOException e)