Does it mean sequence of writing is not guaranteed between these independent Sink1 and Sink2?
On Fri, 6 Jan 2023, 10:44 am Shammon FY, <zjur...@gmail.com> wrote: > Hi @Great > > I think the two sinks in your example are equivalent and independent. If > there are some logical relationships between two sinks, you may need to > create a new combined sink and do it yourself. > > On Thu, Jan 5, 2023 at 11:48 PM Great Info <gubt...@gmail.com> wrote: > >> >> I have a stream from Kafka, after reading it and doing some >> transformations/enrichment I need to store the final data stream in the >> database and publish it to Kafka so I am planning to add two sinks like >> below >> >> >> *finalInputStream.addSink(dataBaseSink); // >> Sink1finalInputStream.addSink( flinkKafkaProducer ); //Sink2 * >> >> Has the sequence guaranteed between Sink1 and Sink2, in my requirement >> stream to sink2 should start to begin only after successfully completing >> Sink1, If Sink1 fails it should not write to Sink2. >> >
