From 75592781e074969b3c9215f12931a22041bba310 Mon Sep 17 00:00:00 2001
From: sitara-a <sitara.achar@gmail.com>
Date: Thu, 5 Sep 2024 17:43:15 -0500
Subject: [PATCH] Fixed Flaky Test in WindowTest.java

---
 .../com/cloudhopper/commons/util/windowing/WindowTest.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/ch-commons-util/src/test/java/com/cloudhopper/commons/util/windowing/WindowTest.java b/ch-commons-util/src/test/java/com/cloudhopper/commons/util/windowing/WindowTest.java
index c79e3dde..e105d4df 100644
--- a/ch-commons-util/src/test/java/com/cloudhopper/commons/util/windowing/WindowTest.java
+++ b/ch-commons-util/src/test/java/com/cloudhopper/commons/util/windowing/WindowTest.java
@@ -315,7 +315,8 @@ public RequestThread(Window<Integer,String,String> window, BlockingQueue<Integer
         public void run() {
             try {
                 for (int x = 0; x < requestsPerThread; x++) {
-                    Integer i = Integer.valueOf(""+id+""+x);
+                    //To get a distinct value of i, we multiply id by the total number of requests per thread and add x to it
+                    Integer i = Integer.valueOf(""+id*requestsPerThread+""+x);
                     String request = "Request"+i;
  //                   logger.debug("adding request " + i);
                     WindowFuture<Integer,String,String> requestFuture = window.offer(i, request, 1000);