Skip to content

Commit

Permalink
rename
Browse files Browse the repository at this point in the history
  • Loading branch information
zwangsheng committed Mar 29, 2023
1 parent 78c9fdb commit b026771
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ class KubernetesApplicationOperation extends ApplicationOperation with Logging {
driverInformer = client.informers().sharedIndexInformerFor(
classOf[Pod],
informerPeriod)
driverInformer.addEventHandler(new EnginePodEventHandler()).start()
driverInformer.addEventHandler(new SparkEnginePodEventHandler()).start()
info("Start Kubernetes Client Informer.")
// Using Cache help clean delete app info
val cachePeriod = conf.get(KyuubiConf.KUBERNETES_INFORMER_CACHE_PERIOD)
Expand Down Expand Up @@ -153,7 +153,7 @@ class KubernetesApplicationOperation extends ApplicationOperation with Logging {
}
}

private class EnginePodEventHandler extends ResourceEventHandler[Pod] {
private class SparkEnginePodEventHandler extends ResourceEventHandler[Pod] {
private def filter(pod: Pod): Boolean = {
pod.getMetadata.getLabels.containsKey(LABEL_KYUUBI_UNIQUE_KEY)
}
Expand Down

0 comments on commit b026771

Please sign in to comment.