(beam) branch master updated: Fix non-unique job names in TextIOReadTest (#38242)

[kenn]

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

kennknowles 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 2ea46979154 Fix non-unique job names in TextIOReadTest (#38242)
2ea46979154 is described below

commit 2ea469791541147fbbe6ac86052a5f5534dfbd00
Author: Subramanya V <subramanyav2...@gmail.com>
AuthorDate: Mon May 18 19:54:51 2026 +0530

    Fix non-unique job names in TextIOReadTest (#38242)
---
 .../core/src/test/java/org/apache/beam/sdk/io/TextIOReadTest.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextIOReadTest.java 
b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextIOReadTest.java
index c475d6d203b..e7d25608eb7 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextIOReadTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextIOReadTest.java
@@ -453,10 +453,12 @@ public class TextIOReadTest {
           getTextSource(path.toString(), null, 0)
               .createForSubrangeOfFile(metadata, 0, metadata.sizeBytes());
 
-      PipelineOptions options = PipelineOptionsFactory.create();
-
       // Check every possible split positions.
       for (int i = 0; i < line.length(); ++i) {
+
+        PipelineOptions options = PipelineOptionsFactory.create();
+        options.setJobName("textio-test-" + i + "-" + 
System.currentTimeMillis());
+
         double fraction = i * 1.0 / line.length();
         FileBasedReader<String> reader = 
source.createSingleFileReader(options);