undo flink test fix

nikhil-zlai · nikhil-zlai · commit 4707538550b0 · 2025-01-15T00:16:14.000-05:00
diff --git a/flink/src/test/scala/ai/chronon/flink/test/SparkExpressionEvalFnTest.scala b/flink/src/test/scala/ai/chronon/flink/test/SparkExpressionEvalFnTest.scala
@@ -39,7 +39,7 @@ class SparkExpressionEvalFnTest extends AnyFlatSpec {
     // let's check the id field
     assert(result.map(_.apply("id")).toSet == Set("test1", "test2", "test3"))
 
-    sparkExprEval.close()
-    env.close()
+    // sparkExprEval.close()
+    // env.close()
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,7 @@ class SparkExpressionEvalFnTest extends AnyFlatSpec {`
`39`	`39`	`// let's check the id field`
`40`	`40`	`assert(result.map(_.apply("id")).toSet == Set("test1", "test2", "test3"))`
`41`	`41`
`42`		`- sparkExprEval.close()`
`43`		`- env.close()`
	`42`	`+ // sparkExprEval.close()`
	`43`	`+ // env.close()`
`44`	`44`	`}`
`45`	`45`	`}`