Skip to content

Commit 14b65a4

Browse files
kevin hogelandliyinan926
kevin hogeland
authored andcommitted
Fix CRD informer version in resource usage watcher (kubeflow#692)
1 parent baafaaf commit 14b65a4

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pkg/webhook/resourceusage/watcher.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -52,13 +52,13 @@ func newResourceUsageWatcher(crdInformerFactory crdinformers.SharedInformerFacto
5252
}
5353
// Note: Events for each handler are processed serially, so no coordination is needed between
5454
// the different callbacks. Coordination is still needed around updating the shared state.
55-
sparkApplicationInformer := r.crdInformerFactory.Sparkoperator().V1beta1().SparkApplications()
55+
sparkApplicationInformer := r.crdInformerFactory.Sparkoperator().V1beta2().SparkApplications()
5656
sparkApplicationInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
5757
AddFunc: r.onSparkApplicationAdded,
5858
UpdateFunc: r.onSparkApplicationUpdated,
5959
DeleteFunc: r.onSparkApplicationDeleted,
6060
})
61-
scheduledSparkApplicationInformer := r.crdInformerFactory.Sparkoperator().V1beta1().ScheduledSparkApplications()
61+
scheduledSparkApplicationInformer := r.crdInformerFactory.Sparkoperator().V1beta2().ScheduledSparkApplications()
6262
scheduledSparkApplicationInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
6363
AddFunc: r.onScheduledSparkApplicationAdded,
6464
UpdateFunc: r.onScheduledSparkApplicationUpdated,

0 commit comments

Comments
 (0)