Hi together
Currently I'm using flink on a docker cluster on AWS.
I would like to use property files with the integrated
ParameterTool.fromPropertiesFile function of Flink.
Locally this version works absolutely fine:
val configuration =
ParameterTool.fromPropertiesFile("src/main/resources/config.properties")
But on the cluster this didn't work, so we introduced this version, which also
doesn't work:
val baseParameters =
ParameterTool.fromPropertiesFile(getClass.getClassLoader.getResource("config.properties").getFile)
gives
java.io.FileNotFoundException: Properties file
file:/tmp/flink-web-upload-57bcc912-bc98-4c89-b5ee-c5176155abd5/992186c1-b3c3-4342-a5c8-67af133155e4pipeline-0.1.0-all.jar!/config.properties
does not exist
The property file is located in src/main/resources.
Do you have any idea of how to integrate such property files into the jar
package?
-Thanks
Simon
