[Spark] [2182] [FOLLOWUP] Add UniForm examples (#2190)

Add UniForm examples - Followup 2181
delta-io · Feb 20, 2024 · 9be2d4d · 9be2d4d
1 parent bd59026
commit 9be2d4d
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/iceberg/src/test/scala/org/apache/spark/sql/delta/ConvertToIcebergSuite.scala b/iceberg/src/test/scala/org/apache/spark/sql/delta/ConvertToIcebergSuite.scala
@@ -115,9 +115,11 @@ class ConvertToIcebergSuite extends QueryTest with Eventually {
 
   def verifyReadWithIceberg(tableName: String, expectedAnswer: Seq[Row]): Unit = {
     withIcebergSparkSession { icebergSparkSession =>
-      Thread.sleep(20000)
-      val icebergDf = icebergSparkSession.read.format("iceberg").load(tableName)
-      checkAnswer(icebergDf, expectedAnswer)
+      eventually(timeout(10.seconds)) {
+        icebergSparkSession.sql(s"REFRESH TABLE ${tableName}")
+        val icebergDf = icebergSparkSession.read.format("iceberg").load(tableName)
+        checkAnswer(icebergDf, expectedAnswer)
+      }
     }
   }