Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-25167

Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

    XMLWordPrintableJSON

Details

    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 no one is working on it, I'm willing to doing that.  : )

      Attachments

        Issue Links

          Activity

            People

              neighborhood Lsw_aka_laplace
              neighborhood Lsw_aka_laplace
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: