[ https://issues.apache.org/jira/browse/BEAM-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Thomas Weise resolved BEAM-6058. -------------------------------- Resolution: Fixed Fix Version/s: 2.10.0 > Support flink config directory for flink runner. > ------------------------------------------------ > > Key: BEAM-6058 > URL: https://issues.apache.org/jira/browse/BEAM-6058 > Project: Beam > Issue Type: Bug > Components: runner-flink > Reporter: Ankur Goenka > Assignee: Ankur Goenka > Priority: Major > Fix For: 2.10.0 > > Time Spent: 8h 40m > Remaining Estimate: 0h > > Give user option to use flink configuration from a config directory. > Earlier we only used jars to submit flink jobs which by default picks the > cluster flink properties. > Portability uses remote environment to submit flink job. In Remote > execution, flink uses the client config instead of the cluster config. This > require us to submit the custom flink properties via flink client. > Suggestion is to read the flink config from a flink configuration folder and > set them to the environment. > -- This message was sent by Atlassian JIRA (v7.6.3#76005)