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
>>>
>>
>>
>
