Hi All,
We use zookeeper to achieve high availability of jobs. Recently, a failure
occurred in our flink cluster. It was due to the abnormal downtime of the
zookeeper service that all the flink jobs using this zookeeper all occurred
failover. The failover startup of a large number of jobs in a s
Hi,
I manged to accomplish this by using side outputs [1] and stream union [2].
We used those in my past projects where we were using exclusively Java
Streaming API to create alerting stream.
Every operator was able to produce a side output stream in case of an
exception/alert. Later we union all
Hello,
We have a query regarding our use case.
Use Case:
We need to send descriptive alerts from Flink operators triggered based on
certain criteria.
Queries:
1. Is there any mechanism provided by Flink, which can be used to send these
alerts?
2. We considered using the Async operators,
Hi David,
Thanks for this useful information. This unblocked and now locally build is
successful which was not the case earlier.
I have a few more questions though.
- Are there any requirements for the maven and / or plugin version ?
- Another error says *Failure to find org.apache.kafka:k
