Hi Dream， 可以分享下你完整的程序吗，我感觉这个是因为 JOIN ON 条件上类型不一致引起的，可以分享下你完整的程序看下。 Best， Hailong Wang
在 2020-10-19 09:50:33，"Dream-底限" <[email protected]> 写道： >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
