to inject
the barrier. After I increased the JM resources, the long start delays
disappeared.
On Thu, May 13, 2021 at 1:56 PM Hubert Chen wrote:
> Hello,
>
> I have an application that reads from two Kafka sources, joins them, and
> produces to a Kafka sink. The application is exper
Hello,
I have an application that reads from two Kafka sources, joins them, and
produces to a Kafka sink. The application is experiencing long end to end
checkpoint durations for the Kafka source operators. I'm hoping I could get
some direction in how to debug this further.
Here is a UI
Hello,
My Flink application has entered into a bad state and I was wondering if I
could get some advice on how to resolve the issue.
The sequence of events that led to a bad state:
1. A failure occurs (e.g., TM timeout) within the cluster
2. The application successfully recovers from the last
