Hi, You can take use of the configuration “pipeline.global-job-parameters” [1] to pass your custom configs all the way into the UDF. For example you can execute this in SQL client:
SET pipeline.global-job-parameters=black_list_path:/root/list.properties; Then you can get the value “/root/list.properties” by context.getJobParameter(“black_list_path”, “your_default_value”) in the open() method of your UDF. [1] https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/config/#pipeline-global-job-parameters Cheers, Qingsheng > On May 11, 2022, at 14:36, wang <24248...@163.com> wrote: > > Hi dear engineer, > > I want to override the function open() in my UDF, like: > > <image.png> > > In open() function, I want to fetch the configred value "black_list_path", > then simply print that value out. And I config this value in ./sql-client.sh > console: > > SET black_list_path = /root/list.properties > > Then I run this UDF, but what printed is /config/list.properties(this is the > default value as I set in context.getJobParameter("black_list_path", > "/config/list/properties")), not /root/list.properties which I set in > ./sql-client.sh console. > > So could you please show me the correct way to set black_list_path is sql ? > Thanks so much! > > > Thanks && Reards, > Hunk > > > > > >
