Re: How to perform something on Checkpointing and Savepointing

CheckpointedFunction / CheckpointListener. Best, Ben On Mon, Sep 12, 2022 at 4:01 PM Surendra Lalwani via user < user@flink.apache.org> wrote: > Hi Team, > > I want to perform some customized operations on checkpointing and > savepointing. For example, I want to create an additional file every

Re: RichFunctions, streaming, and configuration (it's always empty)

Hi David, Thanks for confirming my research. Adding some more up to date documentation to that function seems like an easy first contribution. Best, Ben

Re: RichFunctions, streaming, and configuration (it's always empty)

on off the runtime context, but there is no way to inspect the configuration from the runtime context, unless we are talking about the global job parameters on the execution context. Is that the "right" way to pass configuration? On Sat, Aug 6, 2022 at 6:04 PM Ben Edwards wrote: >

RichFunctions, streaming, and configuration (it's always empty)

I am new to flink and trying to write some unit tests for a RichFunction. This function wants to find configuration passed in via the open method in order to set up a network client. I am using a stream harness for my test, customised with my own MockEnvironment + Configuration. To my surprise, the