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
Hi, 我看其中一个 condition 是 t1.uid = t2.refer_id
其中 uid 是 bigint 类型,refer_id 是 varchar 类型。 你再确认下?*来自志愿者整理的flink
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。