Hi, Xuyang & Daniel.
I have checked this part of code. I think it is an expected behavior.
As marked in code comments, this loop makes sure that the transactions
before this checkpoint id are re-created.
The situation Daniel mentioned will happen only when all checkpoint between
1 and 2 fails
Hi, Danny.
When the problem occurs, can you use flame graph to confirm whether the loop in
this code is causing the busyness?
Since I'm not particularly familiar with kafka connector, I can't give you an
accurate reply. I think Hang Ruan is an expert in this field :).
Hi, Ruan Hang. Can you t
退订
At 2024-02-26 20:55:19, "Salva Alcántara" wrote:
Awesome Andrew, thanks a lot for the info!
On Sun, Feb 25, 2024 at 4:37 PM Andrew Otto wrote:
> the following code generator
Oh, and FWIW we avoid code generation and POJOs, and instead rely on Flink's
Row or RowData abstra
