fix test

apache · Oct 1, 2024 · 7a8f305 · 7a8f305
1 parent a930233
commit 7a8f305
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/IcebergIOWriteTest.java b/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/IcebergIOWriteTest.java
@@ -362,7 +362,7 @@ public void testStreamingWrite() {
             .getSnapshots();
     // verify that 2 snapshots are created (one per triggering interval)
     PCollection<Long> snapshots = output.apply(Count.globally());
-    PAssert.that(snapshots).containsInAnyOrder(1L, 1L);
+    PAssert.that(snapshots).containsInAnyOrder(2L);
     testPipeline.run().waitUntilFinish();
 
     List<Record> writtenRecords = ImmutableList.copyOf(IcebergGenerics.read(table).build());