Skip to content

Commit c4a6de0

Browse files
committed
style: Apply scalafix and scalafmt changes
1 parent 2358fad commit c4a6de0

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

flink/src/main/scala/ai/chronon/flink/FlinkJob.scala

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -305,7 +305,10 @@ object FlinkJob {
305305
env.execute(s"${flinkJob.groupByName}")
306306
}
307307

308-
private def buildFlinkJob(groupByName: String, kafkaBootstrap: Option[String], api: Api, servingInfo: GroupByServingInfoParsed) = {
308+
private def buildFlinkJob(groupByName: String,
309+
kafkaBootstrap: Option[String],
310+
api: Api,
311+
servingInfo: GroupByServingInfoParsed) = {
309312
val topicUri = servingInfo.groupBy.streamingSource.get.topic
310313
val topicInfo = TopicInfo.parse(topicUri)
311314

0 commit comments

Comments
 (0)