A quick workaround is to remove the last '/' from the output path.
I created https://issues.apache.org/jira/browse/FLINK-1640 and will provide
a fix tomorrow.
2015-03-03 21:59 GMT+01:00 Fabian Hueske <fhue...@gmail.com>:
> I reproduced the bug and will look into that.
>
> Cheers, Fabian
>
> 2015-03-03 14:08 GMT+01:00 Sebastian <ssc.o...@googlemail.com>:
>
>> Hi I'm getting strange output paths for this piece of code:
>>
>> computeDistribution(
>> "/home/ssc/Desktop/trackthetrackers/sampleSeg.tsv",
>> "/home/ssc/Entwicklung/datasets/hyperlink2012/pld-index",
>> "/home/ssc/Desktop/trackthetrackers/out/trackerDistribution/")
>>
>> def computeDistribution(trackingGraphFile: String,
>> domainIndexFile: String, outputPath: String) = {
>>
>> ...
>>
>> topTrackerDomains.writeAsCsv(outputPath, fieldDelimiter = "\t",
>> writeMode = WriteMode.OVERWRITE)
>>
>> }
>>
>> For some reasons, the last directory name is repeated twice in the final
>> output:
>>
>> /home/ssc/Desktop/trackthetrackers/out/trackerDistribution/
>> trackerDistribution/
>>
>> How does this come?
>>
>> Best,
>> Sebastian
>>
>
>
