[
https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17461171#comment-17461171
]
Lsw_aka_laplace commented on FLINK-25167:
-----------------------------------------
[~pnowojski] Sorry for late reply. I guess we have reached an agreement on
exposing {{StreamOperatorFactory}}, right? If so, would you mind assigning
this ticket to me? I’ll work on it, thanks.
> 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)
