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)
