Yes.. a custom sink with the required checks seems to be the only option.
From: Hequn Cheng
Sent: 10 July 2018 18:23
To: Teena Kappen // BPRISE
Cc: user@flink.apache.org
Subject: Re: Access the data in a stream after writing to a sink
Hi Teena,
It seems that a sink can not output data into
Hi Teena,
It seems that a sink can not output data into another sink. Maybe we can
implement a combined user defined sink. In the combined sink, only write to
the next sink if the first write is successful.
On Tue, Jul 10, 2018 at 3:23 PM, Teena Kappen // BPRISE <
teena.kap...@bprise.com> wrote:
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:
