our = url.getFile();
>> }
>> if (null == retour) {
>> retour = nom;
>> }
>> return retour;
>> }
>>
>> My JRE version is Oracle 1.8.0.31.
>>
>> I can send you a zip file if you li
retour;
> }
>
> My JRE version is Oracle 1.8.0.31.
>
> I can send you a zip file if you like.
>
> Arnaud
>
> -Message d'origine-
> De : Aljoscha Krettek [mailto:aljos...@apache.org]
> Envoyé : vendredi 24 avril 2015 12:05
> À : user@flink.apache
;
}
return retour;
}
My JRE version is Oracle 1.8.0.31.
I can send you a zip file if you like.
Arnaud
-Message d'origine-
De : Aljoscha Krettek [mailto:aljos...@apache.org]
Envoyé : vendredi 24 avril 2015 12:05
À : user@flink.apache.org
Objet : Re: Flink Java 8 pr
Unfortunately I can't reproduce your error on my machine (OS X, java
8) i created a fresh maven project from your pom and source example
and it runs.
As a workaround you can call
cluster.getConfig().disableClosureCleaner(). The closure cleaner
normally cleans closures from unneeded stuff because w
One thing I noticed a while back with ASM version 4 and Java 8 had issues -
but those were related to Java 8 lambdas.
Back then, bumping ASM to version 5 helped it. Not sure if this is the same
problem, though, since you do not seem to use Java 8 lambdas...
On Fri, Apr 24, 2015 at 11:32 AM, Aljos
I'm looking into it,
On Fri, Apr 24, 2015 at 11:13 AM, LINZ, Arnaud wrote:
> Hi,
>
>
>
> I have the following simple code that works well in Java 7 :
>
>
>
> final ExecutionEnvironment cluster =
> ExecutionEnvironment.createLocalEnvironment();
>
> final DataSet textFile =
> cluste
Hi,
I have the following simple code that works well in Java 7 :
final ExecutionEnvironment cluster =
ExecutionEnvironment.createLocalEnvironment();
final DataSet textFile =
cluster.readTextFile(MiscTools.chercher("jeuDeDonnees.txt"));
final DataSet> words = textFile
