A.获取最新数据offsets——offsets写入offsetLog——优化LogicaLPLam——构造LogicalPlan——计算结果sink——计算完成commit
B.获取最新数据offsets——offsets写入offsetLog——构造LogicalPlan——优化LogicaLPLam———计算完成commit——计算结果sink
C.offsets写入offsetLog——获取最新数据offsets——构造LogicalPlan——优化LogicaLPLam——计算结果sink———计算完成commit
D.获取最新数据offsets——offsets写入offsetLog——构造LogicalPlan——优化LogicaLPLam——计算结果sink———计算完成commit