Flink exceptions alerting made simple (with go!).
go install
go build -o flinkmonitoring
usage: flinkmonitoring [-h|--help] -c|--config "<value>" [-j|--jobid "<value>"]
Listens for exceptions of all / specified flink jobs and
send them to the specified receiver address
Arguments:
-h --help Print help information
-c --config path to config file
-j --jobid optional job id. Default:
poll: 5 # seconds
for: 15 # seconds
mail:
sender: "sendermailaddress"
password: "senderpassword"
receivers:
- "receiver1"
- "receiver2
smtphost: "smtp.gmail.com"
smtpport: "587"
flink:
endpoint: http://localhost:8081
docker build --tag flinkmonitoring .
docker run --network=host -v $PWD/config.yml:/app/config.yml flinkmonitoring -config config.yml