Hey guys, I am trying to add a new runtime operator; To this end, I am following the guide here: http://ci.apache.org/projects/flink/flink-docs-master/internals/add_operator.html and the code itself.
>From what I understood, the run() in ReduceDriver, for instance, should be called every time a reduce() is called. However, I added a breakpoint in ReduceDriver's run method on the first if and called reduce() on a DataSet. When debugging, it seems that the method is not called; I also tried adding a log.info() there. That doesn't get printed either... Obviously, the same goes for System.out.println. Could someone explain the workflow a bit better? When exactly does run() get called and what is ReduceDriver's role? Thanks! Andra
