Hi Anitha, AFAIK DynamicTableSourceFactory doesn’t expose interface for getting parallelism. Could you elaborate on why you need parallelism in table factory? Maybe we could find other ways to fulfill your requirement.
Best regards, Qingsheng > On Apr 7, 2022, at 16:11, Anitha Thankappan <anitha.thankap...@quantiphi.com> > wrote: > > Hi > > I have developed a BigQuery Flink connector by implementing > DynamicTableSourceFactory. > I have a requirement to : > get the configured parallelism value of > StreamExecutionEnvironment in the Factory class. > or > set the parallelism at Factory class or Table source > class level. > Please help me on this. > > > Thanks and Regards, > Anitha Thankappan > > This message contains information that may be privileged or confidential and > is the property of the Quantiphi Inc and/or its affiliates. It is intended > only for the person to whom it is addressed. If you are not the intended > recipient, any review, dissemination, distribution, copying, storage or other > use of all or any portion of this message is strictly prohibited. If you > received this message in error, please immediately notify the sender by reply > e-mail and delete this message in its entirety
