Re: Access Flink configuration in user functions

2018-12-28 Thread Chesnay Schepler
The configuration is not accessible to user-functions or the main method. The could either override ConfigurableStatebackend#configure, or configure the statebackend globally (see https://ci.apache.org/projects/flink/flink-docs-release-1.7/ops/state/state_backends.html#setting-default-state-bac

Access Flink configuration in user functions

2018-12-27 Thread Paul Lam
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) a