You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2018/07/15 17:47:42 UTC
flink git commit: [FLINK-9404] [file sink] Bucketing sink uses target
directory rather than home directory during reflectTruncate
Repository: flink
Updated Branches:
refs/heads/master 0e5ac4d79 -> afb8f825e
[FLINK-9404] [file sink] Bucketing sink uses target directory rather than home directory during reflectTruncate
This closes #6050
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/afb8f825
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/afb8f825
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/afb8f825
Branch: refs/heads/master
Commit: afb8f825ee151804a37b352de6be3504a9bce278
Parents: 0e5ac4d
Author: maqingxiang-it <ma...@dev05v.sys.corp.qihoo.net>
Authored: Mon May 21 12:28:59 2018 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Sun Jul 15 19:44:50 2018 +0200
----------------------------------------------------------------------
.../flink/streaming/connectors/fs/bucketing/BucketingSink.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/afb8f825/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java b/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
index e55aff5..17e5d56 100644
--- a/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
+++ b/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java
@@ -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) {