HPCC4J-624 RowServiceInputStream handle read before close cleanup (#738)

Signed-off-by: James McMullan [email protected]
hpcc-systems · Aug 2, 2024 · 76ab9f4 · 76ab9f4
1 parent da135fb
commit 76ab9f4
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java b/dfsclient/src/main/java/org/hpccsystems/dfs/client/RowServiceInputStream.java
@@ -825,9 +825,6 @@ private int startFetch()
             {
                 try
                 {
-                    // Read handle before closing
-                    this.dis.readInt();
-
                     close();
                 }
                 catch (IOException e)
@@ -889,7 +886,8 @@ else if (this.handle == 0)
             {
                 if (dataLen == 0)
                 {
-                    dataLen = dis.readInt(); // need to read addl int here ...
+                    // Read handle before closing
+                    dis.readInt();
                     close();
                     return 0;
                 }