[fix](routine load) should update progress before handle transaction state transform (#39311) (#39526)
pick (#39311) Update progress maybe throw exception, causing offset has been persisted on edit log or meta service, but the memory data has not been updated. It will cause repeated consumption.
This commit is contained in:
@ -298,8 +298,8 @@ public class KafkaRoutineLoadJob extends RoutineLoadJob {
|
||||
|
||||
@Override
|
||||
protected void updateProgress(RLTaskTxnCommitAttachment attachment) throws UserException {
|
||||
super.updateProgress(attachment);
|
||||
updateProgressAndOffsetsCache(attachment);
|
||||
super.updateProgress(attachment);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
Reference in New Issue
Block a user