You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/09/14 16:34:24 UTC
[flink] 13/16: UpsertTestSinkWriter should create parent directories
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 <ch...@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));