Feature/lazy load offset comparison service

src/main/scala/za/co/absa/hyperdrive/trigger/api/rest/services/CheckpointService.scala

@@ -20,6 +20,7 @@ import org.apache.hadoop.security.UserGroupInformation
 import org.json4s.jackson.Serialization
 import org.json4s.{Formats, NoTypeHints}
 import org.slf4j.LoggerFactory
+import org.springframework.context.annotation.Lazy
 import org.springframework.stereotype.Service
 import za.co.absa.hyperdrive.trigger.api.rest.utils.ScalaUtil.swap
 
@@ -41,8 +42,9 @@ class HdfsParameters(
   val checkpointLocation: String
 )
 
+@Lazy
 @Service
-class CheckpointServiceImpl @Inject() (hdfsService: HdfsService) extends CheckpointService {
+class CheckpointServiceImpl @Inject() (@Lazy hdfsService: HdfsService) extends CheckpointService {
   private val logger = LoggerFactory.getLogger(this.getClass)
   private val offsetsDirName = "offsets"
   private val commitsDirName = "commits"

src/main/scala/za/co/absa/hyperdrive/trigger/api/rest/services/HdfsService.scala

@@ -20,6 +20,7 @@ import org.apache.hadoop.fs._
 import org.apache.hadoop.security.UserGroupInformation
 import org.apache.spark.deploy.SparkHadoopUtil
 import org.slf4j.LoggerFactory
+import org.springframework.context.annotation.Lazy
 import org.springframework.stereotype.Service
 
 import java.nio.charset.StandardCharsets.UTF_8
@@ -36,6 +37,7 @@ trait HdfsService {
   ): Try[Option[R]]
 }
 
+@Lazy
 @Service
 class HdfsServiceImpl extends HdfsService {
   private val logger = LoggerFactory.getLogger(this.getClass)

src/main/scala/za/co/absa/hyperdrive/trigger/api/rest/services/HyperdriveOffsetComparisonService.scala

@@ -22,6 +22,7 @@ import org.apache.commons.configuration2.{BaseConfiguration, Configuration}
 import org.apache.hadoop.security.UserGroupInformation
 import org.apache.kafka.clients.consumer.ConsumerConfig
 import org.slf4j.LoggerFactory
+import org.springframework.context.annotation.Lazy
 import org.springframework.stereotype.Service
 import za.co.absa.hyperdrive.trigger.configuration.application.SparkConfig
 import za.co.absa.hyperdrive.trigger.models.enums.JobTypes
@@ -36,9 +37,10 @@ trait HyperdriveOffsetComparisonService {
 }
 
 @Service
+@Lazy
 class HyperdriveOffsetComparisonServiceImpl @Inject() (sparkConfig: SparkConfig,
-                                                       checkpointService: CheckpointService,
-                                                       userGroupInformationService: UserGroupInformationService,
+                                                       @Lazy checkpointService: CheckpointService,
+                                                       @Lazy userGroupInformationService: UserGroupInformationService,
                                                        kafkaService: KafkaService
 ) extends HyperdriveOffsetComparisonService {
   private val logger = LoggerFactory.getLogger(this.getClass)

src/main/scala/za/co/absa/hyperdrive/trigger/api/rest/services/UserGroupInformationService.scala

@@ -1,4 +1,3 @@
-
 /*
  * Copyright 2018 ABSA Group Limited
  *
@@ -17,12 +16,14 @@
 package za.co.absa.hyperdrive.trigger.api.rest.services
 
 import org.apache.hadoop.security.UserGroupInformation
+import org.springframework.context.annotation.Lazy
 import org.springframework.stereotype.Service
 
 trait UserGroupInformationService {
   def loginUserFromKeytab(principal: String, keytab: String): UserGroupInformation
 }
 
+@Lazy
 @Service
 class UserGroupInformationServiceImpl extends UserGroupInformationService {
   override def loginUserFromKeytab(principal: String, keytab: String): UserGroupInformation =

src/main/scala/za/co/absa/hyperdrive/trigger/scheduler/executors/Executors.scala

@@ -31,6 +31,7 @@ import za.co.absa.hyperdrive.trigger.scheduler.executors.spark.{
 }
 import org.slf4j.LoggerFactory
 import org.springframework.beans.factory.BeanFactory
+import org.springframework.context.annotation.Lazy
 import za.co.absa.hyperdrive.trigger.scheduler.executors.shell.ShellExecutor
 import org.springframework.stereotype.Component
 import za.co.absa.hyperdrive.trigger.api.rest.services.HyperdriveOffsetComparisonService
@@ -48,7 +49,7 @@ class Executors @Inject() (
   beanFactory: BeanFactory,
   implicit val sparkConfig: SparkConfig,
   schedulerConfig: SchedulerConfig,
-  hyperdriveOffsetComparisonService: HyperdriveOffsetComparisonService
+  @Lazy hyperdriveOffsetComparisonService: HyperdriveOffsetComparisonService
 ) {
   private val logger = LoggerFactory.getLogger(this.getClass)
   private implicit val executionContext: ExecutionContextExecutor =