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ö <paul.roewer1...@googlemail.com> 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 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 FlinkBenchmarkLauncher { > > private static List<Long> times = new ArrayList<Long>(); > > public static void main(String[] args) throws Exception { > Properties pro = new Properties(); > > pro.load(FlinkBenchmarkLauncher.class.getResourceAsStream("/config.properties")); > int benchRounds = > Integer.parseInt(pro.getProperty("benchmark.rounds")); > > FileSystem fs = LocalFileSystem.get(new > URI(pro.getProperty("hdfs.namenode")),new > org.apache.hadoop.conf.Configuration()); > String outputPath = > fs.getHomeDirectory()+pro.getProperty("flink.output"); > > for(int i=0;i<benchRounds;i++) { > FlinkMain fm = new FlinkMain((i+1)); > > long start = System.nanoTime(); > fm.run(); > long end = System.nanoTime(); > > times.add(end-start); > if(i!=benchRounds-1) { > fs.delete(new Path(outputPath+"/points"), false); > fs.delete(new Path(outputPath+"/centers"), false); > } > } > BenchmarkHelper.writeTimekeepingToFile(times, "flink_benchmark"); > } > } > > my flink main class. > > public class FlinkMain implements Runnable{ > > private static int benchmarkCounter; > private static int iterationCounter = 1; > > FlinkMain(int benchmarkCounter) { > this.benchmarkCounter = benchmarkCounter; > } > > public void run() { > // my execute > ... > > > 2015-06-26 12:34 GMT+02:00 Pa Rö <paul.roewer1...@googlemail.com>: > >> 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 <rmetz...@apache.org>: >> >>> 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ö <paul.roewer1...@googlemail.com> >>> wrote: >>> >>>> 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 >>>> >>> >>> >> >