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. >
