Skip to content

Commit 2ea4697

Browse files
Fix non-unique job names in TextIOReadTest (apache#38242)
1 parent 233ebd8 commit 2ea4697

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

sdks/java/core/src/test/java/org/apache/beam/sdk/io/TextIOReadTest.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -453,10 +453,12 @@ public void testReadLinesWithDefaultDelimiterOnSplittingSourceAndSlowReadChannel
453453
getTextSource(path.toString(), null, 0)
454454
.createForSubrangeOfFile(metadata, 0, metadata.sizeBytes());
455455

456-
PipelineOptions options = PipelineOptionsFactory.create();
457-
458456
// Check every possible split positions.
459457
for (int i = 0; i < line.length(); ++i) {
458+
459+
PipelineOptions options = PipelineOptionsFactory.create();
460+
options.setJobName("textio-test-" + i + "-" + System.currentTimeMillis());
461+
460462
double fraction = i * 1.0 / line.length();
461463
FileBasedReader<String> reader = source.createSingleFileReader(options);
462464

0 commit comments

Comments
 (0)