Hello
The current Sink operator will be split into two operations, Writer and
Commiter. By default, they will be chained together and executed on the same
thread.
So sometimes when the commiter is very slow, it will block the data writer,
causing back pressure.
At present, FlinkSQL can be so
Hello
Regarding the GlobalCommitter in Flink's two-phase commit,
I see it was introduced in FLIP-143, but it seems to have been removed again in
FLP-191 and marked as Deprecated in the source code.
I haven't found any relevant information about the use of GlobalCommitter.
There are two questio