rebase

apache · Jul 12, 2017 · 2284cde · 2284cde
1 parent 025019f
commit 2284cde
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/dsls/sql/src/test/java/org/apache/beam/dsls/sql/BeamSqlDslUdfUdafTest.java b/dsls/sql/src/test/java/org/apache/beam/dsls/sql/BeamSqlDslUdfUdafTest.java
@@ -87,6 +87,8 @@ public void testUdf() throws Exception{
         .apply("testUdf2",
             BeamSql.query(sql2).withUdf("cubic2", CubicInteger.class, "cubic"));
     PAssert.that(result2).containsInAnyOrder(record);
+
+    pipeline.run().waitUntilFinish();
   }
 
   /**