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 c475d6d203b8..e7d25608eb7b 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 void testReadLinesWithDefaultDelimiterOnSplittingSourceAndSlowReadChannel 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 reader = source.createSingleFileReader(options);