diff --git a/engine/src/main/java/com/datatorrent/stram/client/RecordingsAgent.java b/engine/src/main/java/com/datatorrent/stram/client/RecordingsAgent.java
index aee5c597f7..22261badb7 100644
--- a/engine/src/main/java/com/datatorrent/stram/client/RecordingsAgent.java
+++ b/engine/src/main/java/com/datatorrent/stram/client/RecordingsAgent.java
@@ -522,9 +522,10 @@ private TuplesInfo getTuplesInfo(String appId, String opId, String id, long low,
           lastProcessPartFile = indexLine.partFile;
           try (BufferedReader partBr = new BufferedReader(new InputStreamReader(stramAgent.getFileSystem().open(new Path(dir, indexLine.partFile))))) {
             processPartFile(partBr, queryType, low, high, limit, ports, numRemainingTuples, currentTimestamp, currentWindowLow, currentOffset, info);
+            currentOffset += numTuples;
           }
         }
-        currentOffset += numTuples;
+
         if (numRemainingTuples.longValue() <= 0 || (queryType == QueryType.TIME && currentTimestamp.longValue() > high)) {
           return info;
         }