Re: Implementing Multiple sink

2024-06-03 Thread Mingliang Liu
nks to the filtered streams. > > > > Something like > > > > streamWithMultipleConditions.filter(FilterForCondition1) > > >.addSink(SinkforCondtiton1); > > > > streamWithMultipleConditions.filter(FilterForCondition2) > > > .a

Re: Implementing Multiple sink

2024-06-03 Thread Mingliang Liu
Hi Mejri, Have you checked side outputs? https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/datastream/side_output/ On Mon, Jun 3, 2024 at 8:28 AM mejri houssem wrote: > Hello community, > > We have a use case in our Flink job that requires the implementation of > multiple sink