Hello Nils, I am going to work on a similar issue related to tracking some basics statistics of the intermediate results produced by dataflows during execution.
I just create a Jira issue here: https://issues.apache.org/jira/browse/FLINK-1297 If you already have some work done on extending the monitoring capabilities in a branch, it might be good to sync-up the development in order to avoid duplicated work (e.g. using the same communication channel used to send the data from the task managers to the job manager). -- View this message in context: http://apache-flink-incubator-mailing-list-archive.1008284.n3.nabble.com/Enhance-Flink-s-monitoring-capabilities-tp2573p2713.html Sent from the Apache Flink (Incubator) Mailing List archive. mailing list archive at Nabble.com.