[
https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456224#comment-17456224
]
Piotr Nowojski commented on FLINK-25167:
----------------------------------------
Until we overhaul {{ProcessFunction}} I think exposing
{{StreamOperatorFactory}} wouldn't be a bad idea.
However as [~arvid] noted, {{OperatorCoordinator}} is internal interface and as
of now we do not provide any guarantees for its stability or existence even
between minor bug fix releases. Whether it should be exposed in the future or
not, that's a good question.
> 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)
