Updated Branches: refs/heads/flume-1.4 31d4d57d7 -> fee30380b
FLUME-2032. HDFSEventSink doesn't work in Windows. (Pedro Urbina Escos via Mike Percy) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/fee30380 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/fee30380 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/fee30380 Branch: refs/heads/flume-1.4 Commit: fee30380b3fb365cbde6a4efb2a992bf1068741c Parents: 31d4d57 Author: Mike Percy <[email protected]> Authored: Thu Jun 13 17:24:01 2013 -0700 Committer: Mike Percy <[email protected]> Committed: Thu Jun 13 17:24:35 2013 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/fee30380/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java index af65167..65f4d2c 100644 --- a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java +++ b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java @@ -58,8 +58,6 @@ class BucketWriter { private static final Logger LOG = LoggerFactory .getLogger(BucketWriter.class); - private static String DIRECTORY_DELIMITER = System.getProperty("file.separator"); - /** * This lock ensures that only one thread can open a file at a time. */ @@ -214,9 +212,9 @@ class BucketWriter { fullFileName += codeC.getDefaultExtension(); } - bucketPath = filePath + DIRECTORY_DELIMITER + inUsePrefix + bucketPath = filePath + "/" + inUsePrefix + fullFileName + inUseSuffix; - targetPath = filePath + DIRECTORY_DELIMITER + fullFileName; + targetPath = filePath + "/" + fullFileName; LOG.info("Creating " + bucketPath); callWithTimeout(new CallRunner<Void>() {
