Temporal Join无输出求助：切换为常规Join可正常运行

1. 事件时间线错位（消费起始位置不匹配） #

你在sensors.raw-readings中使用了/*+ OPTIONS('scan.startup.mode'='latest-offset') */，意味着只消费启动后的最新传感器数据，但id_A-id_B作为CDC同步表，可能还未同步到对应传感器事件时间点的id_A映射记录。

时态Join的核心逻辑是：对于每条传感器数据的$rowtime，会查询id_A-id_B在该时间点的快照数据。如果此时id_A-id_B中还没有这个id_A的有效映射（CDC还没同步过来），就不会产生输出。而常规Join是流式关联，只要后续映射数据到达就会关联输出，因此表现出差异。

排查/解决：

• 改为从最早偏移量启动传感器表：OPTIONS('scan.startup.mode'='earliest-offset')，验证是否能关联到历史数据
• 检查id_A-id_B的CDC同步进度，确保传感器数据的$rowtime晚于对应id_A在CDC表中的首次出现时间

2. 时态表的事件时间配置缺失 #

你的id_A-id_B表没有显式定义事件时间和水位线，Flink会默认使用处理时间作为时态表的时间基准，但sensors.raw-readings的$rowtime是事件时间（传感器数据自带的时间戳）。时间体系不一致会导致时态Join无法匹配到正确的快照。

排查/解决：
修改id_A-id_B的创建语句，显式指定事件时间（比如从CDC源的操作时间字段提取）并定义水位线：

CREATE TABLE `id_A-id_B`
(
  id_A STRING,
  id_B INT,
  `$rowtime` TIMESTAMP(3) METADATA FROM 'value.op_ts', -- 用CDC的操作时间作为事件时间
  WATERMARK FOR `$rowtime` AS `$rowtime` - INTERVAL '5' SECOND,
  PRIMARY KEY (id_A) NOT ENFORCED
)
WITH (
  'changelog.mode' = 'upsert'
)
AS (
  SELECT
    COALESCE(`after`.id_A, `before`.id_A, 'unknown') as id_A,
    COALESCE(`after`.id_B, `before`.id_B, -1) AS id_B
  FROM `db.cdc.main-mysql.my_ids`
  WHERE
    op IN ('r', 'c', 'd') AND (
      (`after` IS NOT NULL AND `after`.`id` is NOT null and `after`.`id_B` IS NOT NULL)
      OR
      (`before` IS NOT NULL AND `before`.`id` IS NOT NULL and `before`.`id_B` IS NOT NULL)
    )
);

3. 删除事件导致快照无匹配数据 #

你的id_A-id_B包含了op='d'的删除操作，当某个id_A被删除后，在时态Join查询该id_A的后续传感器数据时，对应时间点的快照中该id_A已经不存在，因此不会输出结果。而常规Join如果是无界流式关联，可能仍会保留之前的映射记录，从而产生输出。

排查/解决：

• 临时移除WHERE条件中op IN ('r', 'c', 'd')里的'd'，验证删除操作是否是导致无输出的原因
• 检查sensors.raw-readings中是否存在id_A已经在id_A-id_B中被删除的情况

4. 主键类型不一致或无效默认值问题 #

你在id_A-id_B中用COALESCE给id_A设置了默认值'unknown'（字符串类型），如果sensors.raw-readings中的id_A是数值类型（比如INT），Flink SQL的严格类型检查会导致关联失败。而常规Join可能因隐式类型转换侥幸匹配，但时态Join对类型一致性要求更严格。

排查/解决：

• 检查两张表id_A的字段类型是否一致，确保类型匹配
• 临时去掉COALESCE的默认值，只保留有效非空的id_A，验证是否能输出结果

内容的提问来源于stack exchange，提问作者JPG