flink table转datastream失败

Sun, 18 Oct 2020 19:51:03 -0700 

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

回复