[
https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17454525#comment-17454525
]
Lsw_aka_laplace commented on FLINK-25167:
-----------------------------------------
[~arvid] Hi, thank you for your kindly reminder!
> {{OperatorCoordinator}} is an internal concept and may break with any release.
Well, I have to say, {{OperatorCoordinator}} is such a wonderful concept which
definitely helps me out. Hope it will be stable and @PublicEnvoling one day.
> overhaul {{ProcessFunction}} to remove the need to expose
> {{StreamOperatorFactory.}}
I'm also *okay* for both solutions. For now, I have made this code change on
our internal Flink code and it works well. Meanwhile the API improvement you
just mentioned above seems better. So feel free to make the decision.
> 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)
