From dcb8aef5c6fbf4a4428ccbfd1c9a092da6069d42 Mon Sep 17 00:00:00 2001 From: James McMullan Date: Thu, 1 Aug 2024 11:14:50 -0400 Subject: [PATCH] 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 James.McMullan@lexisnexis.com --- .../org/hpccsystems/dfs/client/RowServiceInputStream.java | 6 ++---- 1 file changed, 2 insertions(+), 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 index 50b0e10c5..3a8b26b77 100644 --- 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; }