small test fix

apache · Feb 13, 2025 · 5e3a2cc · 5e3a2cc
1 parent 297c309
commit 5e3a2cc
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/IcebergCatalogBaseIT.java b/...io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/IcebergCatalogBaseIT.java
@@ -439,6 +439,7 @@ public void testWriteRead() {
     PCollection<Row> output =
         readPipeline.apply(Managed.read(Managed.ICEBERG).withConfig(config)).getSinglePCollection();
     PAssert.that(output).containsInAnyOrder(inputRows);
+    readPipeline.run().waitUntilFinish();
   }
 
   @Test