diff --git a/src/main/java/org/apache/flink/benchmark/ProcessingTimerBenchmark.java b/src/main/java/org/apache/flink/benchmark/ProcessingTimerBenchmark.java
index 721f31f2..521b3c38 100644
--- a/src/main/java/org/apache/flink/benchmark/ProcessingTimerBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/ProcessingTimerBenchmark.java
@@ -112,7 +112,7 @@ public void processElement(String s, Context context, Collector<String> collecto
                 throws Exception {
             final long currTimestamp = System.currentTimeMillis();
             for (int i = 0; i < timersPerRecord; i++) {
-                context.timerService().registerProcessingTimeTimer(currTimestamp - i - 1);
+                context.timerService().registerProcessingTimeTimer(currTimestamp - timersPerRecord + i);
             }
         }