File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
website/www/site/content/en/documentation Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -6853,7 +6853,7 @@ class EventTimerDoFn(DoFn):
68536853
68546854 @on_timer(TIMER)
68556855 def expiry_callback(self, buffer = DoFn.StateParam(ALL_ELEMENTS)):
6856- state .clear()
6856+ buffer .clear()
68576857
68586858_ = (p | 'Read per user' >> ReadPerUser()
68596859 | 'EventTime timer pardo' >> beam.ParDo(EventTimerDoFn()))
@@ -6905,7 +6905,7 @@ class ProcessingTimerDoFn(DoFn):
69056905 @on_timer(TIMER)
69066906 def expiry_callback(self, buffer = DoFn.StateParam(ALL_ELEMENTS)):
69076907 # Process timer.
6908- state .clear()
6908+ buffer .clear()
69096909
69106910_ = (p | 'Read per user' >> ReadPerUser()
69116911 | 'ProcessingTime timer pardo' >> beam.ParDo(ProcessingTimerDoFn()))
You can’t perform that action at this time.
0 commit comments