Updated Branches: refs/heads/trunk a964e7ab3 -> a97c04657
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/a97c0465 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/a97c0465 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/a97c0465 Branch: refs/heads/trunk Commit: a97c04657b4735d6759f7b66bc9b4df451ab3aab Parents: a964e7a 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:01 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/a97c0465/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>() {
