Thank you!
On 03.03.2015 23:09, Fabian Hueske wrote:
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 <[email protected]
<mailto:[email protected]>>:
I reproduced the bug and will look into that.
Cheers, Fabian
2015-03-03 14:08 GMT+01:00 Sebastian <[email protected]
<mailto:[email protected]>>:
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
