Spark 流“initialPosition”与“startingPosition”？

Question

spark 流中的

initialPosition

和

startingPosition

有什么区别？我已经阅读了 Spark 文档、Delta 表文档、O'Reilly 指南……他们提到了两者，但没有提到它们之间的区别

Answer 1

initialPosition：流作业第一次启动时使用，也决定了开始读取数据的初始偏移量。

startingPosition：当流作业在失败或手动重启后重新启动时使用，还确定重新启动后恢复处理的偏移量。