This is an automated email from the ASF dual-hosted git repository.
shunping pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 06764636f28 fix variable names (#37206)
06764636f28 is described below
commit 06764636f287ce02b5844acd8dbc7d43103d3f29
Author: Cheskel Twersky <[email protected]>
AuthorDate: Fri Jan 2 21:53:25 2026 -0500
fix variable names (#37206)
---
website/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 df0a1dc77ea..13900f3a7ce 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()))
