Hi Do you mean how to disable `chain` in your custom sink connector? Can you give an example of what you want?
On Wed, Feb 15, 2023 at 10:42 PM di wu <676366...@qq.com> wrote: > 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 >
