(flink-benchmarks) branch master updated: Use chronological order timestamp for timers

[pnowojski]

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git


The following commit(s) were added to refs/heads/master by this push:
     new 1b926fd  Use chronological order timestamp for timers
1b926fd is described below

commit 1b926fd97978baf3f9c1bcb9ba0a464eb5ea4d53
Author: Zhiyi Sun <zhiyi...@users.noreply.github.com>
AuthorDate: Tue Sep 10 16:50:35 2024 +0800

    Use chronological order timestamp for timers
---
 src/main/java/org/apache/flink/benchmark/ProcessingTimerBenchmark.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/src/main/java/org/apache/flink/benchmark/ProcessingTimerBenchmark.java 
b/src/main/java/org/apache/flink/benchmark/ProcessingTimerBenchmark.java
index 93a433c..83939b8 100644
--- a/src/main/java/org/apache/flink/benchmark/ProcessingTimerBenchmark.java
+++ b/src/main/java/org/apache/flink/benchmark/ProcessingTimerBenchmark.java
@@ -111,7 +111,7 @@ public class ProcessingTimerBenchmark extends BenchmarkBase 
{
                 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);
             }
         }