[
https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lsw_aka_laplace updated FLINK-25167:
------------------------------------
Description:
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 one is working on it, I'm willing to
doing that. : )
was:Currently, from my side, it is necessary to set my custom
`StreamOperatorFactory` when I ’m calling so that I can set up my own
`OperatorCoordinator`
> 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 one is working on it, I'm willing
> to doing that. : )
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
