From d3f7a83c5be204b272a42ddbfc1bbf7f04283a20 Mon Sep 17 00:00:00 2001 From: Sai Asish Y Date: Fri, 17 Apr 2026 00:36:06 -0700 Subject: [PATCH] Fix 'occured' -> 'occurred' typos across Python, Go, and Java SDKs - sdks/python/apache_beam/runners/worker/data_sampler.py (dataclass field comments) - sdks/go/pkg/beam/runners/prism/internal/engine/teststream.go (code comment) - sdks/java/testing/nexmark/.../generator/Generator.java (Javadoc) No functional changes. Signed-off-by: Sai Asish Y --- sdks/go/pkg/beam/runners/prism/internal/engine/teststream.go | 2 +- .../apache/beam/sdk/nexmark/sources/generator/Generator.java | 2 +- sdks/python/apache_beam/runners/worker/data_sampler.py | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/sdks/go/pkg/beam/runners/prism/internal/engine/teststream.go b/sdks/go/pkg/beam/runners/prism/internal/engine/teststream.go index 97ef84c9f47f..b6466202430d 100644 --- a/sdks/go/pkg/beam/runners/prism/internal/engine/teststream.go +++ b/sdks/go/pkg/beam/runners/prism/internal/engine/teststream.go @@ -230,7 +230,7 @@ func (ev tsWatermarkEvent) Execute(em *ElementManager) { ss.updateUpstreamWatermark(ss.inputID, t.watermark) em.changedStages.insert(sID) } - // Clear the default hold after the inserts have occured. + // Clear the default hold after the inserts have occurred. em.testStreamHandler.UpdateHold(em, t.watermark) } diff --git a/sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java b/sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java index f7f185e4671c..60518b91905b 100644 --- a/sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java +++ b/sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java @@ -56,7 +56,7 @@ public static class NextEvent implements Comparable { /** When, in wallclock time, should this event be emitted? */ public final long wallclockTimestamp; - /** When, in event time, should this event be considered to have occured? */ + /** When, in event time, should this event be considered to have occurred? */ public final long eventTimestamp; /** The event itself. */ diff --git a/sdks/python/apache_beam/runners/worker/data_sampler.py b/sdks/python/apache_beam/runners/worker/data_sampler.py index c95c88f2dbdf..4e4f1a64a508 100644 --- a/sdks/python/apache_beam/runners/worker/data_sampler.py +++ b/sdks/python/apache_beam/runners/worker/data_sampler.py @@ -81,10 +81,10 @@ class ExceptionMetadata: # The repr-ified Exception. msg: str - # The transform where the exception occured. + # The transform where the exception occurred. transform_id: str - # The instruction when the exception occured. + # The instruction when the exception occurred. instruction_id: str