Verify delivery after torn-slot recovery

glasstiger · glasstiger · commit 6328467c85ad · 2026-07-15T21:52:14.000+01:00
diff --git a/core/src/test/java/io/questdb/client/test/cutlass/qwp/client/DeltaDictRecoveryTest.java b/core/src/test/java/io/questdb/client/test/cutlass/qwp/client/DeltaDictRecoveryTest.java
@@ -394,6 +394,10 @@ public void testFullyAckedTornSlotResumesInPlaceWithoutQuarantine() throws Excep
                     while (System.currentTimeMillis() < deadline && handler.maxDictSize() < 1) {
                         Thread.sleep(20);
                     }
+                    Assert.assertEquals(
+                            "the resumed sender must deliver new data from the original slot",
+                            Arrays.asList("after-recovery"),
+                            handler.dictSnapshot());
                 }
             }
             // The fully-acked slot was NOT quarantined: no set-aside copy exists (the

Original file line number	Diff line number	Diff line change
`@@ -394,6 +394,10 @@ public void testFullyAckedTornSlotResumesInPlaceWithoutQuarantine() throws Excep`
`394`	`394`	`while (System.currentTimeMillis() < deadline && handler.maxDictSize() < 1) {`
`395`	`395`	`Thread.sleep(20);`
`396`	`396`	`}`
	`397`	`+ Assert.assertEquals(`
	`398`	`+ "the resumed sender must deliver new data from the original slot",`
	`399`	`+ Arrays.asList("after-recovery"),`
	`400`	`+ handler.dictSnapshot());`
`397`	`401`	`}`
`398`	`402`	`}`
`399`	`403`	`// The fully-acked slot was NOT quarantined: no set-aside copy exists (the`