Classloading in worker thread context

Hi, Due to limitations with Flink's metrics API* I'm using Micrometer to collect supplemental application metrics in my Flink 1.13 application (hosted on Kinesis Data Analytics), and publish them to AWS CloudWatch. For the most part it works well. However when handling errors from CloudWatch, the

Metrics outside of RichFunction context

Hi, I'm using StreamingFileSink to collect records into avro files. Inside of the BulkWriter implementation, I have to do some operations (such as dynamic schema lookup) which I want to record metrics about. However, the BulkWriter API, as it is defined, does not accept a RuntimeContext or Metrics