Disable the chain of the Sink operator

2023-02-15 Thread di wu
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

GlobalCommitter in Flink's two-phase commit

2022-05-24 Thread di wu
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