Have you tried this? context.getConfiguration().get(org.apache.flink.configuration.PipelineOptions.GLOBAL_JOB_PARAMETERS)
On Tue, Nov 9, 2021 at 3:59 PM Krzysztof Chmielewski < krzysiek.chmielew...@gmail.com> wrote: > Hi, > Is there a way to access GlobalJobParameters registered as > env.getConfig().setGlobalJobParameters(parameters); > > from DynamicTableSourceFactory implementation? > To be more specific > from DynamicTableSourceFactory::createDynamicTableSource method. > > The Context parameter of createDynamicTableSource has access only > to ReadableConfig object which does not have GlobalParameters. > > Cheers, > Krzysztof Chmielewski >
