Yank flaky test for now

airbnb · Nov 8, 2023 · ac41085 · ac41085
1 parent 226641f
commit ac41085
Showing 1 changed file with 0 additions and 27 deletions.
diff --git a/flink/src/test/scala/ai/chronon/flink/test/SparkExpressionEvalFnTest.scala b/flink/src/test/scala/ai/chronon/flink/test/SparkExpressionEvalFnTest.scala
@@ -35,31 +35,4 @@ class SparkExpressionEvalFnTest {
     assert(result.map(_.apply("id")).toSet == Set("test1", "test2", "test3"))
   }
 
-  @Test
-  def testSparkExprEvalSkippedEvents(): Unit = {
-    val elements = Seq(
-      E2ETestEvent("test1", 12, 1.5, 1699366993123L),
-      E2ETestEvent("test2", 13, 1.6, 1699366993124L),
-      E2ETestEvent("test3", 14, 1.7, 1699366993125L)
-    )
-
-    val groupBy = FlinkTestUtils.makeGroupBy(Seq("id"), Seq("int_val % 2 == 0"))
-    val encoder = Encoders.product[E2ETestEvent]
-
-    val sparkExprEval = new SparkExpressionEvalFn[E2ETestEvent](
-      encoder,
-      groupBy
-    )
-
-    val env = StreamExecutionEnvironment.getExecutionEnvironment
-    val source: DataStream[E2ETestEvent] = env.fromCollection(elements)
-    val sparkExprEvalDS = source.flatMap(sparkExprEval)
-
-    val result = new DataStreamUtils(sparkExprEvalDS).collect.toSeq
-    // lets check the size
-    assert(result.size == 2, "Expect result sets to include 2 rows")
-    // lets check the id field
-    assert(result.map(_.apply("id")).toSet == Set("test1", "test3"))
-  }
-
 }