Hi, I was looking HdfsState class where createOutputFile api present at line 182 is as follows
Path path = new Path(this.fileNameFormat.getPath(), this.fileNameFormat.getName(this.rotation, System.currentTimeMillis())); whereas there is another createOutputFile at line 272 line Path p = new Path(this.fsUrl + this.fileNameFormat.getPath(), this.fileNameFormat.getName(this.rotation, System.currentTimeMillis())); In line number 182 user has to provide the hdfs uri in path itself, its handled properly in 272 Is there any reason for above difference or its just missed? Thanks, Sachin
