Robin Sylvan created SAMZA-1707:
-----------------------------------

             Summary: Samza onTimer method triggering before init
                 Key: SAMZA-1707
                 URL: https://issues.apache.org/jira/browse/SAMZA-1707
             Project: Samza
          Issue Type: Bug
          Components: container
    Affects Versions: 0.14.1
         Environment:  
 
            Reporter: Robin Sylvan


If you create a samza job with an onTimer method, TimerRegistry registers the 
timer before the container is running. This leads to an edge case where if the 
initial `registerTimer` delay is too small, the onTimer function will never get 
called (this can mean you never get to schedule subsequent timers if your 
onTimer function periodically schedules it's next call).

I ran into this when setting my timer to schedule onTimer events every 250 
milliseconds. One temporary workaround for this is to make the registerTimer 
function have a high initial delay (e.g. 10 seconds).
 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to