Do you also have the rest of the code. It would be helpful in order to find
out why it's not working.
Cheers,
TIll
On Wed, Jul 1, 2015 at 1:31 PM, Pa Rö
wrote:
> now i have implement a time logger in the open and close methods, it is
> wrok fine, but i try to initial the flink class with a para
now i have implement a time logger in the open and close methods, it is
wrok fine, but i try to initial the flink class with a parameter (counter
of benchmark round),
but it will initial always with 0. but i get no exception. what i do wrong?
my benchmark class:
public class FlinkBenchmarkLaunche
Thank you for your quick response.
I just do not understand quite what you mean. I need to define a method in
Java or do you mean that I should use the monitoring in the browser?
2015-06-26 10:09 GMT+02:00 Robert Metzger :
> Hi,
>
> The TaskManager which is running the Sync task is logging when i
Hi,
The TaskManager which is running the Sync task is logging when its starting
the next iteration. I know its not very convenient.
You can also log the time and Iteration id (from the
IterationRuntimeContext) in the open() method.
On Fri, Jun 26, 2015 at 9:57 AM, Pa Rö
wrote:
> hello flink com
hello flink community,
i have write a k means app for clustering temporal geo data. now i want
know how many time flink need for compute one iteration. Is it possible to
measure that, cause of the execution engine of flink?
best regards,
paul
