svn commit: r1363294 - /flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java

[ja...@apache.org]

Author: jarcec
Date: Thu Jul 19 11:20:09 2012
New Revision: 1363294

URL: http://svn.apache.org/viewvc?rev=1363294&view=rev
Log:
FLUME-1373. Remove hardcoded file separator in HDFSEventSink.

(Mubarak Seyed via Jarek Jarcec Cecho)

Modified:
    flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java

Modified: flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java
URL: http://svn.apache.org/viewvc/flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java?rev=1363294&r1=1363293&r2=1363294&view=diff
==============================================================================
--- flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java (original)
+++ flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java Thu Jul 19 11:20:09 2012
@@ -176,8 +176,7 @@ public class HDFSEventSink extends Abstr
     String dirpath = Preconditions.checkNotNull(
         context.getString("hdfs.path"), "hdfs.path is required");
     String fileName = context.getString("hdfs.filePrefix", defaultFileName);
-    // FIXME: Not portable to Windows
-    this.path = dirpath + "/" + fileName;
+    this.path = dirpath + System.getProperty("file.separator") + fileName;
     rollInterval = context.getLong("hdfs.rollInterval", defaultRollInterval);
     rollSize = context.getLong("hdfs.rollSize", defaultRollSize);
     rollCount = context.getLong("hdfs.rollCount", defaultRollCount);