Realtime task error

Hi All,
Recently I started building some replica data source with Flink and tranquility to do some benchmarking with spark streaming. Yesterday I deployed the same against production as parallel to run against heavy load, one of the weird thing I see after very few mint

Any one came across this exception ? I’m guessing it has something to do with curator /zk , I do see some retry exception . The task seems never getting registered with tranquility , not able to come to conclusion as when I debug from IDE it works fine .

~ Biswajit

Hi Biswajit,
I have the same problem as you,

This exception occurs at the same time every day.

I want to know what the cause of the problem is, how do you solve it?

在 2017年7月14日星期五 UTC+8下午2:23:53,biswa…@gmail.com写道: