You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by mp...@apache.org on 2013/06/14 02:24:42 UTC
git commit: FLUME-2032. HDFSEventSink doesn't work in Windows.
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 <mp...@apache.org>
Authored: Thu Jun 13 17:24:01 2013 -0700
Committer: Mike Percy <mp...@apache.org>
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>() {