flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mpe...@apache.org
Subject git commit: FLUME-2032. HDFSEventSink doesn't work in Windows.
Date Fri, 14 Jun 2013 00:24:42 GMT
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 <mpercy@apache.org>
Authored: Thu Jun 13 17:24:01 2013 -0700
Committer: Mike Percy <mpercy@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>() {


Mime
View raw message