Hi! You can't get GLOBAL_JOB_PARAMETERS from DynamicTableSourceFactory#createDynamicTableSource as far as I know, because configuration in that context is from table config, which only contains configuration on table API level.
Could you tell us more about your use case? There are many other ways to configure a table source for example setting the table configs or passing table options (the options after the WITH clause in DDL). Krzysztof Chmielewski <krzysiek.chmielew...@gmail.com> 于2021年11月10日周三 上午6:10写道： > Hi, > Well no, because ReadableContext does not have getConfiguration method ;) > > So like I wrote, I would like to get the GLOBAL_JOB_PARAMETERS from > DynamicTableSourceFactory interface implementations. > I'm talking about DynamicTableSourceFactory:: createDynamicTableSource > method. It seems that I have access only to Table definition fields. > > Regards, > Krzysztof Chmielewski > > wt., 9 lis 2021 o 19:02 Francesco Guardiani <france...@ververica.com> > napisał(a): > >> 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 >>> >>
