[
https://issues.apache.org/jira/browse/FLINK-21065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269200#comment-17269200
]
Robert Metzger commented on FLINK-21065:
----------------------------------------
Please see the attached screenshot. The logs indicate that MiniCluster is used.
The configuration parameter you've mentioned is only evaluated by the client
when generating the JobGraph.
I'd like to forward settings for the runtime.
> Passing configuration from TableEnvironmentImpl to MiniCluster is not
> supported
> -------------------------------------------------------------------------------
>
> Key: FLINK-21065
> URL: https://issues.apache.org/jira/browse/FLINK-21065
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 1.13.0
> Reporter: Robert Metzger
> Priority: Critical
> Attachments: Screenshot 2021-01-21 at 11.31.21.png
>
>
> While trying to fix a bug in Flink's scheduler, I needed to pass a
> configuration parameter from the TableEnvironmentITCase (blink planner) to
> the TaskManager.
> Changing this from:
> {code}
> case "TableEnvironment" =>
> tEnv = TableEnvironmentImpl.create(settings)
> {code}
> to
> {code}
> case "TableEnvironment" =>
> tEnv = TableEnvironmentImpl.create(settings)
> val conf = new Configuration();
> conf.setInteger("taskmanager.numberOfTaskSlots", 1)
> tEnv.getConfig.addConfiguration(conf)
> {code}
> Did not cause any effect on the launched TaskManager.
> It seems that configuration is not properly forwarded through all
> abstractions.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
