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,
我看其中一个 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条件类型是一样的,我这面下游sink使用jdbc时候是可以运行的,但是转换为datastream时候失败了,下面是程序及异常:
>
>streamTableEnv.executeSql(kafkaDDL);//ddl语句见下面日志
>
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
hi、我这面正在将flinktable转换为datastream,现在抛出如下异常,貌似是个bug。。。
table.printSchema();
streamTableEnv.toRetractStream(table,
Types.ROW(TypeConversions.fromDataTypeToLegacyInfo(table.getSchema().getFieldDataTypes(.print();
root
|-- register_id: BIGINT
|-- asi_uid: BIGINT
|-- person_uuid: BIGINT
|-- a