Hi all,
Thank you for the help, I understand now.
On Thu, Oct 15, 2020 at 5:28 PM 阮树斌 浙江大学 wrote:
> hello, Manas Kale.
>
> From the log, it can be found that the exception was thrown on the
> 'open()' method of the RedisSink class. You can inherit the RedisSink
> class, then override the
You will have to create a custom version of the redis connector that
ignores such exceptions.
On 10/15/2020 1:27 PM, Manas Kale wrote:
Hi,
I have a streaming application that pushes output to a redis cluster
sink. I am using the Apache Bahir[1] Flink redis connector for this. I
want to
Hi,
I have a streaming application that pushes output to a redis cluster sink.
I am using the Apache Bahir[1] Flink redis connector for this. I want to
handle the case when the redis server is unavailable.
I am following the same pattern as outlined by them in [1]:
FlinkJedisPoolConfig conf = new
