cleanup

George Jahad · George Jahad · commit e24ff418197f · 2025-02-05T15:25:28.000-08:00
diff --git a/resource-managers/armada/core/src/main/scala/io/armadaproject/spark/scheduler/cluster/armada/ArmadaClusterManager.scala b/resource-managers/armada/core/src/main/scala/io/armadaproject/spark/scheduler/cluster/armada/ArmadaClusterManager.scala
@@ -43,7 +43,6 @@ private[spark] class ArmadaClusterManager extends ExternalClusterManager with Lo
 
   override def createTaskScheduler(sc: SparkContext, masterURL: String): TaskScheduler = {
     val maxTaskFailures = 1
-    logInfo("gbj20 cluster manager")
     new TaskSchedulerImpl(sc, maxTaskFailures, isLocal(sc.conf))
   }
 
diff --git a/resource-managers/armada/core/src/main/scala/io/armadaproject/spark/scheduler/cluster/armada/ArmadaClusterManagerBackend.scala b/resource-managers/armada/core/src/main/scala/io/armadaproject/spark/scheduler/cluster/armada/ArmadaClusterManagerBackend.scala
@@ -139,7 +139,6 @@ private[spark] class ArmadaClusterSchedulerBackend(
     }
 
     override def createDriverEndpoint(): DriverEndpoint = {
-      logInfo("gbj20 driver endpoint")
       new ArmadaDriverEndpoint()
     }
 
diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesExecutorBackend.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/KubernetesExecutorBackend.scala
@@ -193,7 +193,6 @@ private[spark] object KubernetesExecutorBackend extends Logging {
           printUsageAndExit(classNameForEntry)
       }
     }
-    log.info("gbj20 executor")
 
     if (hostname == null) {
       hostname = Utils.localHostName()

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,6 @@ private[spark] class ArmadaClusterManager extends ExternalClusterManager with Lo`
`43`	`43`
`44`	`44`	`override def createTaskScheduler(sc: SparkContext, masterURL: String): TaskScheduler = {`
`45`	`45`	`val maxTaskFailures = 1`
`46`		`- logInfo("gbj20 cluster manager")`
`47`	`46`	`new TaskSchedulerImpl(sc, maxTaskFailures, isLocal(sc.conf))`
`48`	`47`	`}`
`49`	`48`
Original file line number	Diff line number	Diff line change
`@@ -139,7 +139,6 @@ private[spark] class ArmadaClusterSchedulerBackend(`
`139`	`139`	`}`
`140`	`140`
`141`	`141`	`override def createDriverEndpoint(): DriverEndpoint = {`
`142`		`- logInfo("gbj20 driver endpoint")`
`143`	`142`	`new ArmadaDriverEndpoint()`
`144`	`143`	`}`
`145`	`144`
Original file line number	Diff line number	Diff line change
`@@ -193,7 +193,6 @@ private[spark] object KubernetesExecutorBackend extends Logging {`
`193`	`193`	`printUsageAndExit(classNameForEntry)`
`194`	`194`	`}`
`195`	`195`	`}`
`196`		`- log.info("gbj20 executor")`
`197`	`196`
`198`	`197`	`if (hostname == null) {`
`199`	`198`	`hostname = Utils.localHostName()`