可观测性与故障诊断

TDengine 通过 information_schema.ins_streams、information_schema.ins_stream_tasks 和 information_schema.ins_stream_recalculates 提供流式计算运行状态。建议先在流级视图中发现异常，再进入任务级视图定位节点或任务，最后按需查看重算作业。

查看流的总体状态

下面的查询同时显示流状态、错误信息和主要运行指标：

SELECT stream_name,
       status,
       message,
       realtime_lag_ms,
       input_rows_per_sec_1m,
       output_rows_per_sec_1m,
       runner_result_latency_avg_1m_ms,
       history_progress_pct
FROM information_schema.ins_streams
ORDER BY stream_name;

指标	单位	含义
`realtime_lag_ms`	毫秒	最慢有效入口 Reader 的实时处理延迟
`input_rows_per_sec_1m`	行/秒	最近一个完整 60 秒窗口内，Trigger 接纳的逻辑输入速率
`output_rows_per_sec_1m`	行/秒	最近一个完整 60 秒窗口内，所有最终结果 Runner 成功交付的结果速率
`runner_result_latency_avg_1m_ms`	毫秒	最近一个完整 60 秒窗口内，从 Runner 开始处理计算请求到形成逻辑结果的加权平均时间
`history_progress_pct`	百分比	建流时历史数据计算的完成进度，取值为 0 到 100

realtime_lag_ms 选择所有有效入口 Reader 中最慢的进度。已经追平但暂时没有新数据的 Reader 不会使该值持续增长。引用外部数据源的流没有 WAL 实时进度，该字段为 NULL。

输入速率统计过滤和路由后由流实际接纳的逻辑行，输出速率只统计成功交付的最终结果行。因此输入与输出不是同一层数据，不能用二者直接推导丢失率。窗口聚合、过滤以及一个输入产生多个结果等情况都可能使两者不同。

结果延迟不包含请求进入 Runner 前的排队和网络时间，也不包含结果形成后的写入或通知时间。

下钻到任务

当流状态异常、流级指标为 NULL 或需要定位具体节点时，查询任务视图：

SELECT stream_name,
       task_id,
       type,
       deploy_id,
       node_type,
       node_id,
       status,
       last_update,
       message,
       input_rows_per_sec_1m,
       output_rows_per_sec_1m,
       runner_result_latency_avg_1m_ms
FROM information_schema.ins_stream_tasks
WHERE stream_name = 'your_stream_name'
ORDER BY type, deploy_id, task_id;

任务级指标按职责提供：

入口 Reader 提供物理输入速率。它表示 Reader 实际读取和处理的输入行数。
负责最终结果交付的 Runner 提供输出速率和结果形成延迟。
Trigger、计算数据 Reader 和非最终结果 Runner 的上述列为 NULL。

使用 status 查看任务是否正常，并使用 last_update 判断状态和指标是否仍然新鲜。流级视图没有 last_update 列。

分析流任务内存

任务周期日志会记录模块可归属对象的容量估算，不是整个 taosd 进程的 RSS：

Reader：reader_shallow_memory_bytes_estimate 表示浅层结构内存估算。对于 calc Reader，仅统计外层数组及其容量和各 calc info 结构体本身，不包含 AST、计划字符串、过滤器、条件及结构体内部的运行时数组和上下文分配；对于 trigger Reader，统计已知的哈希表、数组、数据块和虚表缓存结构容量，不递归枚举所有嵌套资源。该指标不代表 Reader 拥有的全部内存。引用外部数据源的 Reader 无法通过该接口枚举结构，对应字段为 NA。
Trigger：record=resources 中的 trigger_pool_memory_bytes_estimate 汇总实时/历史上下文对象池的容量。
Runner：runner_owned_memory_bytes_estimate 汇总执行列表节点和已知输出数据块容量；executor_memory_bytes_estimate 汇总每个 executor 任务内部可见的任务对象、算子树、表达式资源、结果块和直接可见的执行器分配。

Runner 的输出数据块和 executor 内存由执行线程在归还执行器或保留续算状态前采样，每个执行器的采样间隔至少为 1 秒；心跳读取最近一次快照，不访问正在计算的算子。其中 executor_memory_bytes_estimate 需要遍历算子树，只在开启 query debug 日志时采样；未开启采样时，已创建但尚未采样过的 executor 上报 NA（不使用初始的 0），此前已采样到的值则继续沿用。单次计算耗时较长时，日志中的内存估算会滞后于当前分配。Trigger 的公共重算统计也按至少 1 秒的间隔刷新，期间复用已有快照。

这些字段只覆盖当前模块能够确认所有权的对象，字段名中的 estimate 表示不包含算子 info 内部无法枚举的嵌套分配、共享缓存或第三方库的未跟踪分配，也不能在模块之间重复求和。建议按 stream_id、task_id 和时间排序，观察容量是否随 table_count、对象池 *_pool_capacity、running_exec_count 或 pending_notify_count 同步增长；若模块估算稳定而进程 RSS 增长，再使用 top 或更细粒度的分配器/执行器分析工具检查未覆盖的分配。

查看历史计算进度

使用 STREAM_OPTIONS(FILL_HISTORY) 或 STREAM_OPTIONS(FILL_HISTORY_FIRST) 创建流后，ins_streams.history_progress_pct 显示初始历史范围的计算进度：

0 到 99：历史计算尚未完成。
100：历史计算已经完成。
NULL：未启用历史计算，或当前没有有效进度信息。

该百分比表示已完成的原始历史时间范围覆盖率，不表示已经输出的结果行比例。

查看手动重算

下面的查询显示每个手动重算作业的范围、进度和状态：

SELECT stream_name,
       recalc_id,
       start,
       end,
       progress,
       status,
       request_time,
       message
FROM information_schema.ins_stream_recalculates
WHERE stream_name = 'your_stream_name'
ORDER BY start, recalc_id;

状态	含义
`Pending`	请求已接受，重算尚未开始
`Running`	重算已经开始，但尚未完成
`Finished`	重算已经完成，进度为 `100%`
`Failed`	发生不可恢复错误，重算无法完成

滚动升级期间，如果旧版本任务只能提供重算进度，status 可能为 NULL，但 progress 仍可用。

SQL 成功返回表示重算请求已被接受，不表示重算已经完成。重算在后台执行；如果服务或流任务重启、重新部署时请求尚未达到终态，未完成的请求会被恢复并继续执行，临时执行失败会自动重试。请使用 recalc_id 跟踪同一个请求，处于 Pending 或 Running 时不要重复提交相同请求。request_time 是 mnode 接受请求的时间，message 在可用时包含重算状态或错误信息。

已结束的重算记录从 mnode 首次观察到终态开始保留 1 小时，每个流最多保留 100 条。Pending 和 Running 记录不受该数量上限影响。记录只保存在内存中，进程重启后可能消失。

上述保留策略只适用于已结束的记录，与未完成请求的持久化恢复机制相互独立。