Adding to the previous question, is it possible to check if each record in a stream was written without any exceptions to a Cassandra Sink? I have to write the records to the next sink only if the first write is successful. So, replicating the streams before the write is not an option.
From: Teena Kappen // BPRISE <teena.kap...@bprise.com> Sent: 10 July 2018 12:50 To: user@flink.apache.org Subject: Access the data in a stream after writing to a sink Hi, Is it possible to access the data in a stream that was written to a sink? I have a Cassandra Sink in my stream job and I have to access all the records that were written to the Cassandra sink and write it to another sink. Is there any way to do that? Regards, Teena
