diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileBasedSinkTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileBasedSinkTest.java index 930ca29fb201f..9f0c424b3cf36 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileBasedSinkTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileBasedSinkTest.java @@ -51,6 +51,7 @@ import org.apache.beam.sdk.io.FileBasedSink.WritableByteChannelFactory; import org.apache.beam.sdk.options.PipelineOptions; import org.apache.beam.sdk.options.PipelineOptionsFactory; +import org.apache.beam.sdk.util.IOChannelUtils; import org.apache.commons.compress.compressors.bzip2.BZip2CompressorInputStream; import org.junit.Rule; import org.junit.Test; @@ -88,8 +89,7 @@ private String getBaseTempDirectory() { @Test public void testWriter() throws Exception { String testUid = "testId"; - String expectedFilename = - getBaseTempDirectory() + "/" + testUid; + String expectedFilename = IOChannelUtils.resolve(getBaseTempDirectory(), testUid); SimpleSink.SimpleWriter writer = buildWriter(); List values = Arrays.asList("sympathetic vulture", "boresome hummingbird"); @@ -488,8 +488,7 @@ public void testFileBasedWriterWithWritableByteChannelFactory() throws Exception .createWriteOperation(null); final FileBasedWriter writer = writeOp.createWriter(null); - final String expectedFilename = - writeOp.tempDirectory.get() + "/" + testUid; + final String expectedFilename = IOChannelUtils.resolve(writeOp.tempDirectory.get(), testUid); final List expected = new ArrayList<>(); expected.add("header");