This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch pull/19923/head in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7733da986c5f7cea8a55e2b69185810184d0ecce Author: Chesnay Schepler <ches...@apache.org> AuthorDate: Wed Sep 14 17:59:47 2022 +0200 UpsertTestSinkWriter should create parent directories --- .../flink/connector/upserttest/sink/UpsertTestSinkWriter.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/connector/upserttest/sink/UpsertTestSinkWriter.java b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/connector/upserttest/sink/UpsertTestSinkWriter.java index c6c8889e951..a91ff3bdfbf 100644 --- a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/connector/upserttest/sink/UpsertTestSinkWriter.java +++ b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/connector/upserttest/sink/UpsertTestSinkWriter.java @@ -27,6 +27,7 @@ import java.io.File; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; +import java.nio.file.Files; import java.util.HashMap; import java.util.Map; @@ -53,6 +54,11 @@ class UpsertTestSinkWriter<IN> implements SinkWriter<IN> { this.keySerializationSchema = checkNotNull(keySerializationSchema); this.valueSerializationSchema = checkNotNull(valueSerializationSchema); checkNotNull(outputFile); + try { + Files.createDirectories(outputFile.toPath().getParent()); + } catch (IOException e) { + throw new FlinkRuntimeException("Could not parent directories for path: " + outputFile); + } try { this.bufferedOutputStream = new BufferedOutputStream(new FileOutputStream(outputFile, true));