flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From simon peyer <simon.pe...@soom-it.ch>
Subject Import Configuration File in Flink Cluster
Date Mon, 23 May 2016 13:56:59 GMT
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
Mime
View raw message