Flink CDC这种复杂的sql查询flink好像1.13.6不支持，哪位朋友们知道如何解决吗？

根据您提供的代码和报错信息，问题可能出在子查询中的online_ddi.state和offline_ddi.state。在子查询中，您使用了别名online_ddi和offline_ddi，但在子查询的WHERE子句中又引用了它们的state属性。这可能导致Flink CDC无法正确解析查询语句。

为了解决这个问题，您可以尝试将子查询中的online_ddi.state和offline_ddi.state替换为实际的表名和列名。以下是修改后的代码：

SELECT
dvi.id,
COALESCE(
CASE
WHEN online_ddi.id IS NOT NULL THEN 'online'
WHEN offline_ddi.id IS NOT NULL THEN 'offline'
ELSE 'notActive'
END,
'notActive'
) AS state
FROM
dev_vehicle_instance dvi
LEFT JOIN
dev_device_instance online_ddi
ON
online_ddi.id IN (
SELECT die.device_instance_id
FROM dev_device_instance_ext die
LEFT JOIN vehicle_device_instance_relation vdir ON die.id = vdir.device_instance_id
WHERE vdir.veh_instance_id = dvi.id AND die.state = 'online'
)
LEFT JOIN
dev_device_instance offline_ddi
ON
offline_ddi.id IN (
SELECT die.device_instance_id
FROM dev_device_instance_ext die
LEFT JOIN vehicle_device_instance_relation vdir ON die.id = vdir.device_instance_id
WHERE vdir.veh_instance_id = dvi.id AND die.state = 'offline'
);

这样修改后，您的查询语句应该可以在Flink CDC中正常执行。如果仍然遇到问题，请检查其他部分的代码是否有误。