hi、
是的，类型部分不匹配，类型改完之后程序运行正常了，感谢
hailongwang <18868816...@163.com> 于2020年10月20日周二 下午4:13写道：
> Hi,
> 我看其中一个 condition 是 `t1.uid = t2.refer_id`
> 其中 uid 是 bigint 类型，refer_id 是 varchar 类型。
> 你再确认下？
>
>
> Best,
> Hailong Wang
>
>
>
>
> At 2020-10-20 08:55:34, "Dream-底限" wrote:
> >hi、
> >我查看了一下，join
hi、
我查看了一下，join条件类型是一样的，我这面下游sink使用jdbc时候是可以运行的，但是转换为datastream时候失败了，下面是程序及异常：
streamTableEnv.executeSql(kafkaDDL);//ddl语句见下面日志
Table table = streamTableEnv.sqlQuery("SELECT cast(t1.id as bigint) as
register_id,cast(t1.uid as bigint) as asi_uid,cast(null as bigint) as
person_uuid,cast(t1.app_id
