我猜测,要是可以在invoke的时候,拿到sink当前对应的barriar的话,从这个barriar取出offset,或者在richSinkFunction时,调用getRuntimeContext()上下文对象,从这个上下文中,拿到当前的task metrics,从而取出task的offset
-- Sent from: http://apache-flink.147419.n8.nabble.com/
我猜测,要是可以在invoke的时候,拿到sink当前对应的barriar的话,从这个barriar取出offset,或者在richSinkFunction时,调用getRuntimeContext()上下文对象,从这个上下文中,拿到当前的task metrics,从而取出task的offset
-- Sent from: http://apache-flink.147419.n8.nabble.com/