We have some custom Flink sinks that need to use a batching approach, and we 
use timers to facilitate flushing. Currently, we’re casting the 
`RuntimeContext` provided by `RichFunction.getRuntimeContext()` to a 
`StreamingRuntimeContext` (which it always seems to be?), which then gives us 
access to `ProcessingTimeService` as a scheduler. Is there any chance of either 
`getProcessingTimeService` being added to `RuntimeContext`, or some other 
scheduling facility being exposed? With the runtime cast, if the implementation 
changes during an upgrade, our jobs can be completely broken without any 
compiler errors, which is a big source of exposure in our project.


*Confidentiality Notice: The information contained in this e-mail and any

attachments may be confidential. If you are not an intended recipient, you

are hereby notified that any dissemination, distribution or copying of this

e-mail is strictly prohibited. If you have received this e-mail in error,

please notify the sender and permanently delete the e-mail and any

attachments immediately. You should not retain, copy or use this e-mail or

any attachment for any purpose, nor disclose all or any part of the

contents to any other person. Thank you.*

Reply via email to