diff --git a/dfsclient/src/test/java/org/hpccsystems/dfs/client/DFSReadWriteTest.java b/dfsclient/src/test/java/org/hpccsystems/dfs/client/DFSReadWriteTest.java
index b963ea4b1..6eab980e1 100644
--- a/dfsclient/src/test/java/org/hpccsystems/dfs/client/DFSReadWriteTest.java
+++ b/dfsclient/src/test/java/org/hpccsystems/dfs/client/DFSReadWriteTest.java
@@ -179,11 +179,12 @@ public void readResumeTest() throws Exception
         }
 
         Runtime runtime = Runtime.getRuntime();
+        int readSizeKB = 100;
         ArrayList<HPCCRecord> resumedRecords = new ArrayList<HPCCRecord>();
         for (int i = 0; i < resumeInfo.size(); i++)
         {
             HPCCRecordBuilder recordBuilder = new HPCCRecordBuilder(file.getProjectedRecordDefinition());
-            HpccRemoteFileReader<HPCCRecord> fileReader = new HpccRemoteFileReader<HPCCRecord>(fileParts[resumeFilePart.get(i)], originalRD, recordBuilder, -1, -1, true, -1, resumeInfo.get(i));
+            HpccRemoteFileReader<HPCCRecord> fileReader = new HpccRemoteFileReader<HPCCRecord>(fileParts[resumeFilePart.get(i)], originalRD, recordBuilder, -1, -1, true, readSizeKB, resumeInfo.get(i));
 
             if (fileReader.hasNext())
             {
@@ -202,6 +203,10 @@ public void readResumeTest() throws Exception
             {
                 runtime.gc();
             }
+            fileReader.close();
+
+            fileReader = null;
+            recordBuilder = null;
         }
 
         assertEquals("Number of records did not match during read resume.", records.size(), resumedRecords.size());