RowServiceInputStream handle read before close cleanup

- Removed incorrect handle read, clarified why reading an additional int is needed during close Signed-off-by: James McMullan [email protected]
hpcc-systems · Aug 1, 2024 · dcb8aef · dcb8aef
1 parent 1834b0c
commit dcb8aef
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;
                 }