Fix compile error

airbnb · Feb 28, 2024 · 2f53c7e · 2f53c7e
1 parent aab3496
commit 2f53c7e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink/src/test/scala/ai/chronon/flink/test/FlinkJobIntegrationTest.scala b/flink/src/test/scala/ai/chronon/flink/test/FlinkJobIntegrationTest.scala
@@ -118,7 +118,7 @@ class FlinkJobIntegrationTest {
       FlinkTestUtils.makeTestGroupByServingInfoParsed(groupBy, encoder.schema, outputSchema)
     val mockApi = mock[Api](withSettings().serializable())
     val writerFn = new MockAsyncKVStoreWriter(Seq(true), mockApi, "testTiledFlinkJobEndToEndFG")
-    val job = new FlinkJob[E2ETestEvent](source, writerFn, groupByServingInfoParsed, encoder, 2, true)
+    val job = new FlinkJob[E2ETestEvent](source, writerFn, groupByServingInfoParsed, encoder, 2)
     job.runTiledGroupByJob(env).addSink(new CollectSink)
 
     env.execute("TiledFlinkJobIntegrationTest")