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);