117笔记问答Apache Flink 是一个流处理框架，而 Hive 是一个基于 Hadoop 的数据仓库工具
- 检查点（Checkpointing）：Flink 支持检查点机制，它允许你在处理过程中定期保存应用程序的状态。当发生故障时，Flink 可以从最近的检查点恢复应用程序状态，从而保证数据处理的正确性和一致性。要启用检查点，你需要在 Flink 作业中设置
enableCheckpointing()方法，并指定检查点的间隔。
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.enableCheckpointing(60000); // 设置检查点间隔为 60 秒
- 保存点（Savepoints）：除了检查点之外，Flink 还支持保存点机制。保存点是一种更灵活的状态管理机制，允许你在不停止作业的情况下更新应用程序的状态。这对于需要升级或修改作业的场景非常有用。要创建一个保存点，你需要调用
executeSavepoint()方法，并指定保存点的名称。
env.executeSavepoint("my-savepoint");
- Hive 数据存储的容错：Hive 默认使用 HDFS 作为数据存储引擎。HDFS 具有很高的容错性，因为它将数据分布在多个节点上，并且可以自动复制数据以应对节点故障。要配置 Hive 使用 HDFS，你需要在 Hive 配置文件（如
hive-site.xml）中设置fs.defaultFS属性。
fs.defaultFS hdfs://localhost:9000
- Hive 查询的容错：Hive 支持查询容错，这意味着当查询执行失败时，它可以自动重新执行失败的查询。要启用查询容错，你需要在 Hive 配置文件（如
hive-site.xml）中设置hive.exec.parallel和hive.exec.parallel.thread属性。
hive.exec.parallel true hive.exec.parallel.thread 8
通过以上配置，你可以在 Flink 和 Hive 中实现容错机制，从而保证数据处理的正确性和一致性。