You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/02/25 07:37:00 UTC
[jira] [Created] (FLINK-16274) Add typed builder methods for
setting dynamic configuration on StatefulFunctionsAppContainers
Tzu-Li (Gordon) Tai created FLINK-16274:
-------------------------------------------
Summary: Add typed builder methods for setting dynamic configuration on StatefulFunctionsAppContainers
Key: FLINK-16274
URL: https://issues.apache.org/jira/browse/FLINK-16274
Project: Flink
Issue Type: New Feature
Components: Stateful Functions, Test Infrastructure
Affects Versions: statefun-1.1
Reporter: Tzu-Li (Gordon) Tai
Assignee: Tzu-Li (Gordon) Tai
Excerpt from: https://github.com/apache/flink-statefun/pull/32#discussion_r383644382
Currently, you'd need to provide a complete {{Configuration}} as dynamic properties when constructing a {{StatefulFunctionsAppContainers}}.
It'll be nicer if this is built like this:
{code}
public StatefulFunctionsAppContainers verificationApp =
new StatefulFunctionsAppContainers("sanity-verification", 2)
.withModuleGlobalConfiguration("kafka-broker", kafka.getBootstrapServers())
.withConfiguration(ConfigOption option, configValue)
{code}
And by default the {{StatefulFunctionsAppContainers}} just only has the configs in the base template {{flink-conf.yaml}}.
This would require lazy construction of the containers on {{beforeTest}}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)