I have created a custom annotation to log time consumed by a method using aspectj library. I tested it in a spring boot application for one of the rest endpoint and it works fine.
But when I annotate map method in my flink job class, it doesn't work. Anyone having any inputs on it? With regards