We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 59668a9 commit fdfa2afCopy full SHA for fdfa2af
1 file changed
pkg/eventservice/event_broker.go
@@ -342,8 +342,6 @@ func (c *eventBroker) tickTableTriggerDispatchers(ctx context.Context) error {
342
case <-ticker.C:
343
c.tableTriggerDispatchers.Range(func(key, value interface{}) bool {
344
stat := value.(*atomic.Pointer[dispatcherStat]).Load()
345
- c.processTableTriggerDispatcher(ctx, key.(common.DispatcherID), stat)
346
-
347
if !c.activateDispatcherControlPlane(stat) {
348
return true
349
}
0 commit comments