[
https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17454500#comment-17454500
]
Arvid Heise edited comment on FLINK-25167 at 12/7/21, 9:23 AM:
---------------------------------------------------------------
Let me include [~pnowojski]. I think he wanted to overhaul {{ProcessFunction}}
to remove the need to expose {{StreamOperatorFactory}}. But I'm also open for
your suggestion for the meantime.
A quick reminder that {{OperatorCoordinator}} is an internal concept and may
break with any release. Also note that state management of the coordinator is
currently not fleshed out and only works for exactly once use cases at sources.
was (Author: arvid):
Let me include [~pnowojski]. I think he wanted to overhaul `ProcessFunction` to
remove the need to expose `StreamOperatorFactory`. But I'm also open for your
suggestion for the meantime.
A quick reminder that `OperatorCoordinator` is an internal concept and may
break with any release. Also note that state management of the coordinator is
currently not fleshed out and only works for exactly once use cases at sources.
> Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform
> ----------------------------------------------------------------------------
>
> Key: FLINK-25167
> URL: https://issues.apache.org/jira/browse/FLINK-25167
> Project: Flink
> Issue Type: Improvement
> Components: API / DataStream
> Reporter: Lsw_aka_laplace
> Priority: Minor
>
> From my side, it is necessary to set my custom `StreamOperatorFactory` when
> I ’m calling `ConnectedStreams`#transform so that I can set up my own
> `OperatorCoordinator`.
> Well, currently, `ConnectStreams` seems not to give the access, the default
> behavior is using `SimpleOperatorFactory`. After checking the code, I think
> it is a trivial change to support that. If no one is working on it, I'm
> willing to doing that. : )
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
