Hi Vishwas,
took me some time to find out as well. If you have your properties file
under lib following will work:
val kafkaPropertiesInputStream =
getClass.getClassLoader.getResourceAsStream("lib/config/kafka.properties")
Hope this helps,
Maxim.
On Wed, Jul 17, 2019 at 7:23 PM Vishwas Siravara
Does the -yt option work for standalone cluster without dedicated resource
manager ? So this property file is read by one of the dependencies inside
my application as a file, so I can't really use Parameter tool to parse the
config file.
Thanks,
Vishwas
On Fri, Jun 28, 2019 at 11:08 PM Yun Tang
Hi Vishwas
1. You could use '-yt' to ship specified files to the class path, please
refer to [1] for more details.
2. If the properties are only loaded on client side before executing the
application, you could let your application to just read from local property
data. Flink support to
