[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Access Flink configuration in user functions

The configuration is not accessible to user-functions or the main method.

The could either override ConfigurableStatebackend#configure, or configure the statebackend globally (see, the backend factory does get access to it I believe.

On 28.12.2018 05:56, Paul Lam wrote:
Hi to all,

I would like to use a custom RocksDBStateBackend which uses the default checkpoint dir in Flink configuration, but I failed to find a way to access Flink configuration in the user code. So I wonder is it possible to retrieve Flink configurations (not user-defined global parameters) at the user main method? Or the configuration is only used internally? Thanks!

Paul Lam