[
https://issues.apache.org/jira/browse/BEAM-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16949726#comment-16949726
]
Thomas Weise commented on BEAM-8115:
------------------------------------
The first case will allow to change all runner and SDK worker options, so that
will be valuable.
Regarding transform properties, it is correct that there is no solution that
will work with status quo. For our custom transform translations, we can
interpolate properties to do the replacement.
For Beam transforms, I wonder if there could be a different value provider that
binds on deserialization in the worker, i.e. property value isn't part of the
transform, just the pointer to it.
> Overwrite portable Flink application jar pipeline options at runtime
> --------------------------------------------------------------------
>
> Key: BEAM-8115
> URL: https://issues.apache.org/jira/browse/BEAM-8115
> Project: Beam
> Issue Type: New Feature
> Components: runner-flink
> Reporter: Kyle Weaver
> Assignee: Kyle Weaver
> Priority: Major
>
> In the first iteration of portable Flink application jars, all pipeline
> options are set at job creation time and cannot be later modified at runtime.
> There should be a way to pass arguments to the jar to write/overwrite
> pipeline options.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
