From 2f53c7e736df03158621ade032acfbebba0f3816 Mon Sep 17 00:00:00 2001 From: Caio Camatta Date: Wed, 28 Feb 2024 09:46:38 -0500 Subject: [PATCH] Fix compile error --- .../scala/ai/chronon/flink/test/FlinkJobIntegrationTest.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 82dcd5d0b..83f4bd55d 100644 --- 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")