Hi Darren,
No, you cannot access the Task from the operator. You can access some metrics
via the RuntimeContext.
getRuntimeContext().getMetricGroup()
How does the backpressure help you here? Backpressure can originate in any
operator or network connection. If it's an operator further
Hi, is there a way for the UDF of a source function, extended from
RichParallelSourceFunction, to access its Task instance, so as to call
Task.isBackPressured()?
I'm trying to give priorities to different input sources that need to be
managed from within the same source function and want to
