Well,
the use case is rather simple, just pass a JVM parameter to the Table
Source's underlying code and the property should not be exposed to Table
Definition.
Like something that end user should not change but its driven via
application properties. For example you are running SQL that should use
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
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 h
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.getCo
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
