提交 afb8f825 编写于 作者: M maqingxiang-it 提交者: Stephan Ewen

[FLINK-9404] [file sink] Bucketing sink uses target directory rather than home...

[FLINK-9404] [file sink] Bucketing sink uses target directory rather than home directory during reflectTruncate

This closes #6050
上级 0e5ac4d7
......@@ -631,7 +631,7 @@ public class BucketingSink<T>
}
// verify that truncate actually works
Path testPath = new Path(UUID.randomUUID().toString());
Path testPath = new Path(basePath, UUID.randomUUID().toString());
try (FSDataOutputStream outputStream = fs.create(testPath)) {
outputStream.writeUTF("hello");
} catch (IOException e) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册