Hi, It lacks a version of RichAsyncFunction class in the scala API or the possibility to handle a class which extends AbstractRichFunction and implements AsyncFunction (from the scala API).
I made a small dev on our current flink fork because we need to use the open method to add our custom metrics from getRuntimeContext.getMetricGroup method. https://github.com/aphilippot/flink/commit/acbd49cf2d64163040f2f954ce55917155b408ba Do you already plan to release this feature soon ? Do you want me to create a new Jira ticket, propose a pull request ? Antoine
