flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Marcela Charfuelan <charfuelanol...@tu-berlin.de>
Subject Re: Iterations problem in command line
Date Mon, 29 Feb 2016 16:57:57 GMT
Thanks Fabian,
I am using in both default options, since I am not testing in a cluster 
yet, just local in ubuntu, I am not specifying any parallelism.
just to test I set in the program env.setParallelism(1) and running with 
-p 1 (which I guess I would not need) but I am still getting the same issue.


On 29.02.2016 16:44, Fabian Hueske wrote:
> Hi Marcela,
> do you run the algorithm in both setups with the same parallelism?
> Best, Fabian
> 2016-02-26 16:52 GMT+01:00 Marcela Charfuelan
> <charfuelanoliva@tu-berlin.de <mailto:charfuelanoliva@tu-berlin.de>>:
>     Hello,
>     I implemented an algorithm that includes iterations (EM algorithm)
>     and I am getting different results when running in eclipse (Luna
>     Release (4.4.0)) and when running in the command line using Flink
>     run; the program does not crash is just that after the first
>     iteration the results are different (wrong in the command line).
>     The solution I am getting in eclipse, for each iteration, is the
>     same that I would get if running the algorithm in octave for
>     example, so I am sure the solution is correct.
>     I have tried using java plus the command-line arguments of eclipse
>     on the command line and that also works ok (local in ubuntu).
>     Has anybody experienced something similar? Any idea why this could
>     happen? how can I fix this?
>     Regards,
>     Marcela.

View raw message