flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Strange output paths in Flink 0.8.1
Date Tue, 03 Mar 2015 22:09:48 GMT
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 <fhueske@gmail.com>:

> I reproduced the bug and will look into that.
>
> Cheers, Fabian
>
> 2015-03-03 14:08 GMT+01:00 Sebastian <ssc.open@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
>>
>
>

Mime
View raw message