[jira] [Created] (FLINK-16274) Add typed builder methods for setting dynamic configuration on StatefulFunctionsAppContainers

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-16274) Add typed builder methods for setting dynamic configuration on StatefulFunctionsAppContainers

Shang Yuanchun (Jira)
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)