From 79eeecfa2842da0a6379e55c62eae5195685fd36 Mon Sep 17 00:00:00 2001 From: Caio Camatta Date: Tue, 12 Dec 2023 19:19:21 -0500 Subject: [PATCH] rm debug=true --- flink/src/main/scala/ai/chronon/flink/FlinkJob.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink/src/main/scala/ai/chronon/flink/FlinkJob.scala b/flink/src/main/scala/ai/chronon/flink/FlinkJob.scala index 2b20eee008..6d9c32bb59 100644 --- a/flink/src/main/scala/ai/chronon/flink/FlinkJob.scala +++ b/flink/src/main/scala/ai/chronon/flink/FlinkJob.scala @@ -160,8 +160,8 @@ class FlinkJob[T](eventSrc: FlinkSource[T], .sideOutputLateData(tilingLateEventsTag) .aggregate( // See Flink's "ProcessWindowFunction with Incremental Aggregation" - preAggregator = new FlinkRowAggregationFunction(groupByServingInfoParsed.groupBy, inputSchema, debug = true), - windowFunction = new FlinkRowAggProcessFunction(groupByServingInfoParsed.groupBy, inputSchema, debug = true) + preAggregator = new FlinkRowAggregationFunction(groupByServingInfoParsed.groupBy, inputSchema), + windowFunction = new FlinkRowAggProcessFunction(groupByServingInfoParsed.groupBy, inputSchema) ) .uid(s"tiling-01-$featureGroupName") .name(s"Tiling for $featureGroupName")