Merge pull request #927 from teozkr/backport/0.73/applier-hang

[0.73 backport] fix applier hangs which can happen with many watched objects (#925)
kube-rs · Jun 3, 2022 · 29b2468 · 29b2468
2 parents 22bd877 + c676438
commit 29b2468
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kube-runtime/src/controller/mod.rs b/kube-runtime/src/controller/mod.rs
@@ -231,7 +231,7 @@ where
 {
     let (scheduler_shutdown_tx, scheduler_shutdown_rx) = channel::oneshot::channel();
     let err_context = context.clone();
-    let (scheduler_tx, scheduler_rx) = channel::mpsc::channel::<ScheduleRequest<ReconcileRequest<K>>>(100);
+    let (scheduler_tx, scheduler_rx) = channel::mpsc::unbounded::<ScheduleRequest<ReconcileRequest<K>>>();
     // Create a stream of ObjectRefs that need to be reconciled
     trystream_try_via(
         // input: stream combining scheduled tasks and user specified inputs event