如何配置检查点以重新部署Spark Streaming应用程序？

我正在使用Spark流计算唯一用户。我使用updateStateByKey，所以我需要配置一个检查点目录。在启动应用程序时，我还从检查点加载了数据，如doc中的示例所示：

// Function to create and setup a new StreamingContext
def functionToCreateContext(): StreamingContext = {
    val ssc = new StreamingContext(...)   // new context
    val lines = ssc.socketTextStream(...) // create DStreams
    ...
    ssc.checkpoint(checkpointDirectory)   // set checkpoint directory
    ssc
}

// Get StreamingContext from checkpoint data or create a new one
val context = StreamingContext.getOrCreate(checkpointDirectory, functionToCreateContext _)

这里的问题是，如果更改了我的代码，那么我将重新部署该代码，无论更改了多少代码，都会加载检查点吗？或者，我需要使用自己的逻辑来持久化数据并在下一次运行中加载它们。

如果我使用自己的逻辑来保存和加载DStream，那么如果应用程序在失败时重新启动，那么从检查点目录和我自己的数据库中加载的数据都不会吗？