一、Mysql中的隐式COMMIT以及Savepoints的作用     Mysql默认是自动提交的，如果要开启使用事务，首先要关闭自动提交后START TRANSACTION 或者 BEGIN 来开始一个事务，使用ROLLBACK/COMMIT来结束一个事务。但即使如此，也并不是所有的操作都能被ROLLBACK，以下语句在执行后会导致回滚失效，比如DDL语句创建一个数据库，而且不止此，这样的语

Savepoints 1.什么是 Savepoints Savepoint 是依据 Flink checkpointing 机制所创建的流作业执行状态的镜像，可以使用 Savepoint 进行 Flink 作业的停止、重启或更新。 Savepoint 由两部分组成：稳定存储（例如 HDFS，S3，…) 上包含二进制文件的目录（通常很大）和元数据文件（相对较小）。 稳定存储上的文件表示作业执

Flink系列之：Checkpoints 与 Savepoints 一、概述二、功能和限制 一、概述 从概念上讲，Flink 的 savepoints 与 checkpoints 的不同之处类似于传统数据库系统中的备份与恢复日志之间的差异。 Checkpoints 的主要目的是为意外失败的作业提供恢复机制。 Checkpoint 的生命周期 由 Flink 管理， 即 Flin

Flink系列之：Savepoints 一、Savepoints二、分配算子ID三、Savepoint 状态四、算子五、触发Savepoint六、Savepoint 格式七、触发 Savepoint八、使用 YARN 触发 Savepoint九、使用 Savepoint 停止作业十、从 Savepoint 恢复十一、跳过无法映射的状态恢复十二、Restore 模式十三、NO_CLAIM （默

Flink系列之：Savepoints 一、Savepoints二、分配算子ID三、Savepoint 状态四、算子五、触发Savepoint六、Savepoint 格式七、触发 Savepoint八、使用 YARN 触发 Savepoint九、使用 Savepoint 停止作业十、从 Savepoint 恢复十一、跳过无法映射的状态恢复十二、Restore 模式十三、NO_CLAIM （默

Flink系列之：Checkpoints 与 Savepoints 一、概述二、功能和限制 一、概述 从概念上讲，Flink 的 savepoints 与 checkpoints 的不同之处类似于传统数据库系统中的备份与恢复日志之间的差异。 Checkpoints 的主要目的是为意外失败的作业提供恢复机制。 Checkpoint 的生命周期 由 Flink 管理， 即 Flin

什么是Savepoints Savepoints是通过Flink检查点机制创建的流作业的执行状态快照。 保存点仅包含这些运算符的状态，无状态运算符不属于保存点。 Savepoints作用 可以使用保存点停止和继续，派生或更新Flink作业（通常用于flink任务的新版本发布更新）。 2大组成部分

语法 SAVEPOINT 名称 RELEASE SAVEPOINT 名称 ROLLBACK TRANSACTION TO SAVEPOINT 名称 Savepoints 与BEGIN和COMMIT类似的创建事务的方法，名称不要求唯一且可以嵌套使用。 可以用在BEGIN…COMMIT定义的事务内部或外部。当在外部时，最外层的savepoint相当于BEGIN DEFERRED TRANSAC