Flink CDC2.2 任务停止 新加表 从checkpoint恢复 会报错?

当您在Flink CDC 2.2任务停止的状态下新加表并从checkpoint恢复时，会出现错误。

根据错误信息，错误发生在org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.restore方法中。这可能是由于新加的表在checkpoint中没有相应的状态信息导致的。

在Flink CDC中，每个表的状态信息会被保存在Flink的状态后端中，以便在故障恢复或从保存点恢复时恢复状态。当您停止任务后，新加表并从checkpoint恢复时，Flink会尝试恢复所有先前存在的表的状态信息。然而，由于新加的表在之前的checkpoint中没有相应的状态信息，因此会导致恢复失败并抛出该错误。

解决此问题的一种方法是重新启动任务而不从之前的checkpoint中恢复。在重新启动任务时，Flink会重新建立表并初始化其状态，以便与新加的表保持一致。

请注意，重新启动任务将丢失之前的状态信息，因此在做出决定之前请确保您对状态的丢失没有任何影响。如果状态的一致性对您的应用程序至关重要，您可以考虑使用其他的持久化方案，如外部数据库或分布式存储系统，来保存和恢复表的状态信息。

另外，根据错误信息，还可以尝试查看更详细的错误堆栈跟踪，以获得更具体的调试信息，帮助您解决问题。