开发者社区> 问答> 正文

flink table转datastream失败

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 |-- app_id: BIGINT |-- country_id: BIGINT |-- channel_id: STRING |-- device_id: STRING |-- adjust_id: STRING |-- google_adid: STRING |-- referrer: BIGINT |-- login_pwd: STRING |-- sync_data_flag: INT |-- register_phone_number: STRING |-- device_type: INT |-- imei: STRING |-- device_model: STRING |-- os_version: STRING |-- app_name: STRING |-- app_version: STRING |-- app_package_name: STRING |-- network_type: STRING |-- wifi_mac: STRING |-- longitude: DECIMAL(38, 18) |-- latitude: DECIMAL(38, 18) |-- geo_hash7: STRING |-- ip: STRING |-- register_time: BIGINT |-- etl_time: BIGINT NOT NULL

org.apache.flink.table.api.TableException: BIGINT and VARCHAR(2147483647) does not have common type now*来自志愿者整理的flink

展开
收起
毛毛虫雨 2021-12-06 15:36:17 1346 0
1 条回答
写回答
取消 提交回答
  • Hi, 我看其中一个 condition 是 t1.uid = t2.refer_id 其中 uid 是 bigint 类型,refer_id 是 varchar 类型。 你再确认下?*来自志愿者整理的flink

    2021-12-06 16:05:08
    赞同 1 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载