时间戳

首页 > 解决方案 > Flink SQL Savepoint 在 sql-client.sh 中不起作用

apache-flink - Flink SQL Savepoint 在 sql-client.sh 中不起作用

问题描述

我不确定如何在 sql-client.sh 中使用保存点，我尝试使用以下步骤进行测试。它没有成功。

你能帮我理解我做错了什么吗？

Flink 1.13 版本

脚步

  1. 从主题获取数据的 Kafka 源。
  2. 主题包含只有一个属性的json，user_id值为number
  3. 我尝试user_id使用以下 sql 进行分组并获取计数 select user_id,count(*) from kafkaTableSingleColumn group by user_id;
  4. 我将数据摄取到 kafka 主题中{user_id: 1}
  5. 我能够看到预期的结果 sql-client 表格输出。
  6. 我使用 job_id 创建了一个保存点
    ./bin/flink stop --savepointPath /tmp/flink-savepoints $JOB_ID
  7. 在我重新启动sql-client.sh` 并创建我的 kafka 表后，我执行了以下命令
set 'execution.savepoint.path' = '/tmp/flink-checkpoints-directory/532e40d44cd7deab604a8c8000879acd';

select user_id,count(*)
from kafkaTableSingleColumn
group by user_id;
  1. 我再次将数据摄取到 kafka 主题中{user_id: 1}
  2. 我期望我的聚合查询的输出具有输出，user_id 1 count 2但我得到的值为user_id 1 count 1.
  3. 我相信这不是我预期的输出，我相信保存点恢复没有成功。
  4. 我是否缺少任何配置属性或我的步骤错误。

标签： apache-flinkflink-streamingflink-sql

解决方案

推荐阅读