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 20:59:12 GMT
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