SQL语句等周一上班时我再发出来
> 在 2022年10月22日，17:08，yinghua_zh <yinghua...@163.com> 写道： > > > >> 在 2022年10月22日，17:06，yinghua_zh <yinghua...@163.com> 写道： >> >> 感谢答复，Flink版本1.14.4 >> >>>>> 在 2022年10月22日，17:01，Leonard Xu <xbjt...@gmail.com> 写道： >>>>> >>>>> 你好，你的Flink 版本多少呀？我记得低版本才有这个问题。 >>>>> 另外SQL可以贴下嘛？ >>>>> >>>>> 祝好， >>>>> Leonard >>>>> >>>>> >>>>> >>>>>> 2022年10月22日 上午11:11，邮件帮助中心 <yinghua...@163.com> 写道： >>>>> >>>>> 大家好！ >>>>> 最近在开发一个项目时，在使用CDC表和维表表做Temporal Table >>>>> JOIN时，发现2个表Join时join字段的类型必须一致，否则提交时提示如下的错误 >>>>> The main method caused an error: Temporal table join requires an equality >>>>> condition on fields of table..... >>>>> 为了解决上述问题，我们做了如下尝试： >>>>> 1：在join时，对维表要关联的字段使用cast转换，如： JOIN ON CAST(tableA.filedA AS INT) = >>>>> cdc_table_b.fieldB,将2个关联表的关联字段类型保持一致 >>>>> 2：在维表上建立一个视图，在视图定义字段的类型和select时使用cast转换，然后视图和cdc表进行join, >>>>> 此时join时字段类型理论上是一致的， >>>>> 很可惜，上述2个解决办法未能解决问题，都是提示上述同样的错误（The main method caused an error: Temporal >>>>> table join requires an equality condition on fields of >>>>> table），如果在DDL中将维表要jion的字段和CDC表join的字段定义成相同的类型时，提交时不报上述错误，但在运行过程中处理数据时会出现castException，请教下大家上述问题可以怎么解决？不胜感激！ >>>
