对于Flink CDC，有大佬遇到过这个问题吗？加了表然后从checkpoint启动就报这个

原因：

此错误表示你正在使用的 TableSink（在本例中可能是 Flink CDC 表连接器）没有实现 java.io.Serializable 接口。当 Flink 从检查点恢复时，需要对任务进行序列化，其中包括 TableSink。如果 TableSink 不可序列化，则 Flink 无法恢复任务。

解决方案：

有两种方法可以解决此问题：

使 TableSink 实现 java.io.Serializable 接口： 这是最简单的方法，但是可能需要修改 TableSink 的源代码。
使用 AggregatingState 或 FoldingState： 这些类是 Flink 提供的序列化状态后端，可以用于存储不可序列化的对象。你可以将 TableSink 状态存储在这些后端中，从而使 TableSink 整体可序列化。
具体实现：

方法 1：实现 java.io.Serializable 接口

在 TableSink 类中添加以下代码：

public class MyTableSink implements TableSink, java.io.Serializable {
// ...
}
方法 2：使用 AggregatingState 或 FoldingState

在 TableSink 类中添加以下代码：

public class MyTableSink implements TableSink {

private AggregatingState<Long, Long> countState;

@Override
public void open(Configuration parameters) {
    countState = getRuntimeContext().getAggregatingState(
        new ValueStateDescriptor<>("count", LongSerializer.INSTANCE, 0L));
}

// ...

}
在上面的示例中，countState 是一个 AggregatingState，用于存储不可序列化的对象（在本例中为 Long）。

注意：

如果 TableSink 只能通过依赖项进行访问，则可能无法直接修改其源代码。在这种情况下，可以使用方法 2。
AggregatingState 和 FoldingState 仅适用于状态后端，例如 RocksDB 或 StateBackend。