diff --git a/website/www/site/content/en/documentation/programming-guide.md b/website/www/site/content/en/documentation/programming-guide.md index df0a1dc77ea7..13900f3a7ceb 100644 --- a/website/www/site/content/en/documentation/programming-guide.md +++ b/website/www/site/content/en/documentation/programming-guide.md @@ -6853,7 +6853,7 @@ class EventTimerDoFn(DoFn): @on_timer(TIMER) def expiry_callback(self, buffer = DoFn.StateParam(ALL_ELEMENTS)): - state.clear() + buffer.clear() _ = (p | 'Read per user' >> ReadPerUser() | 'EventTime timer pardo' >> beam.ParDo(EventTimerDoFn())) @@ -6905,7 +6905,7 @@ class ProcessingTimerDoFn(DoFn): @on_timer(TIMER) def expiry_callback(self, buffer = DoFn.StateParam(ALL_ELEMENTS)): # Process timer. - state.clear() + buffer.clear() _ = (p | 'Read per user' >> ReadPerUser() | 'ProcessingTime timer pardo' >> beam.ParDo(ProcessingTimerDoFn()))