You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jr...@apache.org on 2025/08/05 18:55:42 UTC

(beam) branch master updated: Fix options.go flag comments (#35785)

This is an automated email from the ASF dual-hosted git repository.

jrmccluskey 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 a247319eb61 Fix options.go flag comments (#35785)
a247319eb61 is described below

commit a247319eb619c71a5fd29501180859f8d647e968
Author: Jack McCluskey <34...@users.noreply.github.com>
AuthorDate: Tue Aug 5 14:55:35 2025 -0400

    Fix options.go flag comments (#35785)
---
 sdks/go/pkg/beam/options/jobopts/options.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/sdks/go/pkg/beam/options/jobopts/options.go b/sdks/go/pkg/beam/options/jobopts/options.go
index 04348b1d1ae..9e4f18364ef 100644
--- a/sdks/go/pkg/beam/options/jobopts/options.go
+++ b/sdks/go/pkg/beam/options/jobopts/options.go
@@ -91,17 +91,17 @@ var (
 	// executing them and fails early if the pipelines don't pass.
 	Strict = flag.Bool("beam_strict", false, "Apply additional validation to pipelines.")
 
-	// Flag to retain docker containers created by the runner. If false, then
+	// RetrainDockerContainers flag to retain docker containers created by the runner. If false, then
 	// containers are deleted once the job ends, even if it failed.
 	RetainDockerContainers = flag.Bool("retain_docker_containers", false, "Retain Docker containers created by the runner.")
 
-	// Flag to set the degree of parallelism. If not set, the configured Flink default is used, or 1 if none can be found.
+	// Parallelisn flag to set the degree of parallelism. If not set, the configured Flink default is used, or 1 if none can be found.
 	Parallelism = flag.Int("parallelism", -1, "The degree of parallelism to be used when distributing operations onto Flink workers.")
 
 	// ResourceHints flag takes whole pipeline hints for resources.
 	ResourceHints stringSlice
 
-	// Flag to set the timeout for processing an element in a PTransform operation. If set to -1, there is no timeout.
+	// ElementProcessingTimeout flag to set the timeout for processing an element in a PTransform operation. If set to -1, there is no timeout.
 	ElementProcessingTimeout = flag.Duration("element_processing_timeout", -1, "The timeout for processing an element in a PTransform operation. If set to -1, there is no timeout.")
 )