From 6023f7e2ddfc1c461d880afe8201578a6a7f5bcb Mon Sep 17 00:00:00 2001 From: Cheskel Twersky Date: Wed, 31 Dec 2025 16:28:16 -0500 Subject: [PATCH] fix variable names --- .../www/site/content/en/documentation/programming-guide.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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()))