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 solved by disabling the chain globally, and 
DataStream can partially disable the chain through the disableChaining method, 
but both of them need to be set by the user.


Can the strategy of the Chain be changed in the Custom Sink Connector to 
separate Writer and Commiter?



Thanks && Regards,


di.wu

Reply via email to