💥 Proposal

In the current implementation of FlinkCustomNodeContext we have exceptionHandlerPreparer: RuntimeContext => ExceptionHandler. With new Flink API there are changes (for example for sinks) which cause that context is not being retrieved via RichFunction#getRuntimeContext method and context is being passed down explicitly via constructor injection.

We should change the signature of this function to (RuntimeContext | WriterInitContext | ... ) => ExceptionHandler (this ADT will probably expand while adapting other components to use new API).

We also should add new analogous trait for WithExceptionHandler since it uses a self-type requirement: self: RichFunction and new sink2.Sink does not conform this requirement.