sjwiesman opened a new pull request #32: [FLINK-16149][hotfix][core] Use GlobalConfiguration.loadConfiguration() on StreamPlanEnvironment URL: https://github.com/apache/flink-statefun/pull/32 This is a follow up to #27 Because the statefun-flink-launcher is based on JobClusterEntrypoint it pulls the StreamGraph using a StreamPlanEnvironment. In this case, the StreamExecutionEnviornment configuration is set to an empty object. The only way to pull the actual flink-conf in this case is via GlobalConfiguration.loadConfiguration(). This is safe because StreamPlanEnvironment implies job based deployment. In all other cases the configuration is still pulled via reflection. I've tested this using statefun images and deploying against a local session cluster. cc @tzulitai @igalshilman
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
